add price resource

Author: saminegash

src/app.module.ts

@@ -3,7 +3,7 @@ import { ConfigModule, ConfigService } from '@nestjs/config';
 
 import { TypeOrmModule } from '@nestjs/typeorm';
 import configuration from './config/configuration';
-
+import { PriceModule } from './price/price.module';
 @Module({
   imports: [
     ConfigModule.forRoot({
@@ -24,6 +24,7 @@ import configuration from './config/configuration';
       }),
       inject: [ConfigService],
     }),
+    PriceModule,
   ],
 })
 export class AppModule {}

src/price/dto/create-price.dto.ts

@@ -0,0 +1 @@
+export class CreatePriceDto {}

src/price/dto/update-price.dto.ts

@@ -0,0 +1,4 @@
+import { PartialType } from '@nestjs/swagger';
+import { CreatePriceDto } from './create-price.dto';
+
+export class UpdatePriceDto extends PartialType(CreatePriceDto) {}

src/price/entities/price.entity.ts

@@ -0,0 +1,21 @@
+import {
+  Entity,
+  Column,
+  PrimaryGeneratedColumn,
+  CreateDateColumn,
+} from 'typeorm';
+
+@Entity()
+export class Price {
+  @PrimaryGeneratedColumn()
+  id: number;
+
+  @Column()
+  chain: string;
+
+  @Column('decimal', { precision: 10, scale: 2 })
+  price: number;
+
+  @CreateDateColumn()
+  timestamp: Date;
+}

src/price/price.controller.spec.ts

@@ -0,0 +1,26 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { PriceController } from './price.controller';
+import { PriceService } from './price.service';
+
+describe('PriceController', () => {
+  let controller: PriceController;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      controllers: [PriceController],
+      providers: [
+        PriceService,
+        {
+          provide: 'PriceRepository',
+          useValue: {}, // Mock implementation of PriceRepository
+        },
+      ],
+    }).compile();
+
+    controller = module.get<PriceController>(PriceController);
+  });
+
+  it('should be defined', () => {
+    expect(controller).toBeDefined();
+  });
+});

src/price/price.controller.ts

@@ -0,0 +1,15 @@
+import { Controller, Get } from '@nestjs/common';
+import { PriceService } from './price.service';
+import { ApiTags, ApiOperation } from '@nestjs/swagger';
+
+@ApiTags('prices')
+@Controller('prices')
+export class PriceController {
+  constructor(private readonly priceService: PriceService) {}
+
+  @Get('last-24-hours')
+  @ApiOperation({ summary: 'Get prices for the last 24 hours' })
+  async getPricesLast24Hours() {
+    return this.priceService.getPricesLast24Hours();
+  }
+}

src/price/price.module.ts

@@ -0,0 +1,13 @@
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { PriceService } from './price.service';
+import { PriceController } from './price.controller';
+import { Price } from './entities/price.entity';
+
+@Module({
+  imports: [TypeOrmModule.forFeature([Price])],
+  providers: [PriceService],
+  controllers: [PriceController],
+  exports: [PriceService],
+})
+export class PriceModule {}

src/price/price.service.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { PriceService } from './price.service';
+
+describe('PriceService', () => {
+  let service: PriceService;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [PriceService],
+    }).compile();
+
+    service = module.get<PriceService>(PriceService);
+  });
+
+  it('should be defined', () => {
+    expect(service).toBeDefined();
+  });
+});

src/price/price.service.ts

@@ -0,0 +1,41 @@
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { MoreThanOrEqual, Repository } from 'typeorm';
+import { Price } from './entities/price.entity';
+import { ConfigService } from '@nestjs/config';
+
+@Injectable()
+export class PriceService {
+  constructor(
+    @InjectRepository(Price)
+    private priceRepository: Repository<Price>,
+    private configService: ConfigService,
+  ) {}
+
+  async savePrices() {
+    //TODO
+    // Implement Moralis API call to get prices
+    // Save prices to the database
+  }
+
+  async getPricesLastHour(chain: string): Promise<Price[]> {
+    const oneHourAgo = new Date(Date.now() - 60 * 60 * 1000);
+    return this.priceRepository.find({
+      where: {
+        chain,
+        timestamp: MoreThanOrEqual(oneHourAgo),
+      },
+      order: { timestamp: 'DESC' },
+    });
+  }
+
+  async getPricesLast24Hours(): Promise<Price[]> {
+    const oneDayAgo = new Date(Date.now() - 24 * 60 * 60 * 1000);
+    return this.priceRepository.find({
+      where: {
+        timestamp: MoreThanOrEqual(oneDayAgo),
+      },
+      order: { timestamp: 'DESC' },
+    });
+  }
+}