feat: create order

Author: marian2js

apps/api/src/chat/chat.module.ts

@@ -17,15 +17,18 @@ import { Campaign, CampaignAuthorizer } from './entities/campaign'
 import { CampaignMessage } from './entities/campaign-message'
 import { Contact, ContactAuthorizer } from './entities/contact'
 import { Menu, MenuAuthorizer } from './entities/menu'
+import { Order, OrderAuthorizer } from './entities/order'
 import { CampaignResolver } from './resolvers/campaign.resolver'
 import { ContactResolver } from './resolvers/contact.resolver'
 import { MenuResolver } from './resolvers/menu.resolver'
+import { OrderResolver } from './resolvers/order.resolver'
 import { BroadcastConsumer } from './services/broadcast.consumer'
 import { CampaignMessageService } from './services/campaign-message.service'
 import { CampaignService } from './services/campaign.service'
 import { ContactsConsumer } from './services/contact.consumer'
 import { ContactService } from './services/contact.service'
 import { MenuService } from './services/menu.service'
+import { OrderService } from './services/order.service'
 
 @Module({
   imports: [
@@ -45,6 +48,10 @@ import { MenuService } from './services/menu.service'
       imports: [NestjsQueryTypegooseModule.forFeature([Menu])],
       dtos: [{ DTOClass: Menu }],
     }),
+    NestjsQueryGraphQLModule.forFeature({
+      imports: [NestjsQueryTypegooseModule.forFeature([Order])],
+      dtos: [{ DTOClass: Order }],
+    }),
     BullModule.registerQueue({
       name: 'broadcast',
       settings: {
@@ -78,18 +85,22 @@ import { MenuService } from './services/menu.service'
     ContactResolver,
     CampaignResolver,
     MenuResolver,
+    OrderResolver,
 
     // Services
     ContactService,
     CampaignService,
     CampaignMessageService,
     MenuService,
+    OrderService,
 
     // Authorizers
     ContactAuthorizer,
     CampaignAuthorizer,
     MenuAuthorizer,
+    OrderAuthorizer,
 
+    // Consumers
     BroadcastConsumer,
     ContactsConsumer,
   ],

apps/api/src/chat/entities/order-item.ts

@@ -0,0 +1,31 @@
+import { Field, InputType, ObjectType } from '@nestjs/graphql'
+import { prop } from '@typegoose/typegoose'
+
+@ObjectType()
+export class OrderItem {
+  @Field()
+  @prop({ required: true, set: (name) => name.trim() })
+  name: string
+
+  @Field()
+  @prop({ required: true })
+  quantity: number
+}
+
+@InputType()
+export class CreateOrderItemInput {
+  @Field()
+  name: string
+
+  @Field()
+  quantity: number
+}
+
+@InputType()
+export class UpdateOrderItemInput {
+  @Field({ nullable: true })
+  name: string
+
+  @Field({ nullable: true })
+  quantity: number
+}

apps/api/src/chat/entities/order.ts

@@ -0,0 +1,74 @@
+import { BaseEntity } from '@app/common/base/base-entity'
+import { OwnedAuthorizer } from '@app/common/base/owned.authorizer'
+import { OwnedEntity } from '@app/common/decorators/owned-entity.decorator'
+import { Reference } from '@app/common/typings/mongodb'
+import { Injectable } from '@nestjs/common'
+import { Field, InputType, ObjectType } from '@nestjs/graphql'
+import { Authorize } from '@ptc-org/nestjs-query-graphql'
+import { prop } from '@typegoose/typegoose'
+import { getAddress, isAddress } from 'ethers/lib/utils'
+import { User } from '../../users/entities/user'
+import { CreateOrderItemInput, OrderItem, UpdateOrderItemInput } from './order-item'
+
+export enum OrderState {
+  PendingPayment = 'pending-payment',
+  PendingDelivery = 'pending-delivery',
+  Completed = 'completed',
+}
+
+@Injectable()
+export class OrderAuthorizer extends OwnedAuthorizer<Order> {}
+
+@ObjectType()
+@OwnedEntity()
+@Authorize<Order>(OrderAuthorizer)
+export class Order extends BaseEntity {
+  @prop({ ref: User, required: true, index: true })
+  readonly owner!: Reference<User>
+
+  @Field()
+  @prop({ required: true, validate: isAddress, set: (addr) => addr && getAddress(addr) })
+  address: string
+
+  @Field()
+  @prop({ required: true, default: 0 })
+  total: number
+
+  @prop({ required: true })
+  @Field()
+  state: OrderState
+
+  @Field(() => [OrderItem])
+  @prop({ default: [] })
+  items: OrderItem[]
+}
+
+@InputType()
+export class CreateOrderInput {
+  @Field()
+  address: string
+
+  @Field({ nullable: true })
+  total: number
+
+  @Field()
+  state: OrderState
+
+  @Field(() => [CreateOrderItemInput])
+  items: CreateOrderItemInput[]
+}
+
+@InputType()
+export class UpdateOrderInput {
+  @Field({ nullable: true })
+  address: string
+
+  @Field({ nullable: true })
+  total: number
+
+  @Field({ nullable: true })
+  state: OrderState
+
+  @Field(() => [UpdateOrderItemInput], { nullable: true })
+  items: UpdateOrderItemInput[]
+}

apps/api/src/chat/resolvers/order.resolver.ts

@@ -0,0 +1,20 @@
+import { BaseResolver } from '@app/common/base/base.resolver'
+import { UseGuards, UseInterceptors } from '@nestjs/common'
+import { Resolver } from '@nestjs/graphql'
+import { Authorizer, AuthorizerInterceptor, InjectAuthorizer } from '@ptc-org/nestjs-query-graphql'
+import { GraphqlGuard } from '../../auth/guards/graphql.guard'
+import { CreateOrderInput, Order, UpdateOrderInput } from '../entities/order'
+import { OrderService } from '../services/order.service'
+
+@Resolver(() => Order)
+@UseGuards(GraphqlGuard)
+@UseInterceptors(AuthorizerInterceptor(Order))
+export class OrderResolver extends BaseResolver(Order, {
+  CreateDTOClass: CreateOrderInput,
+  UpdateDTOClass: UpdateOrderInput,
+  guards: [GraphqlGuard],
+}) {
+  constructor(protected orderService: OrderService, @InjectAuthorizer(Order) readonly authorizer: Authorizer<Order>) {
+    super(orderService)
+  }
+}

apps/api/src/chat/services/order.service.ts

@@ -0,0 +1,16 @@
+import { BaseService } from '@app/common/base/base.service'
+import { Injectable, Logger } from '@nestjs/common'
+import { ReturnModelType } from '@typegoose/typegoose'
+import { InjectModel } from 'nestjs-typegoose'
+import { Order } from '../entities/order'
+
+@Injectable()
+export class OrderService extends BaseService<Order> {
+  protected readonly logger = new Logger(OrderService.name)
+  static instance: OrderService
+
+  constructor(@InjectModel(Order) protected readonly model: ReturnModelType<typeof Order>) {
+    super(model)
+    OrderService.instance = this
+  }
+}

apps/runner/src/services/runner.service.ts

@@ -679,7 +679,7 @@ export class RunnerService {
     ownerId: string,
     onError: () => any,
   ) {
-    if (workflow.type !== 'chatbot' || integration.key !== 'chatbot') {
+    if (workflow.type !== 'chatbot' || !['chatbot', 'orders'].includes(integration.key)) {
       return this.getCredentialsAndIntegrationAccount(credentialsId, ownerId, onError)
     }
 

generated/graphql.ts

@@ -161,6 +161,11 @@ export enum MenuSortFields {
     createdAt = "createdAt"
 }
 
+export enum OrderSortFields {
+    id = "id",
+    createdAt = "createdAt"
+}
+
 export enum UserDatabaseSortFields {
     id = "id",
     createdAt = "createdAt"
@@ -552,6 +557,19 @@ export interface MenuSort {
     nulls?: Nullable<SortNulls>;
 }
 
+export interface OrderFilter {
+    and?: Nullable<OrderFilter[]>;
+    or?: Nullable<OrderFilter[]>;
+    id?: Nullable<IDFilterComparison>;
+    createdAt?: Nullable<DateFieldComparison>;
+}
+
+export interface OrderSort {
+    field: OrderSortFields;
+    direction: SortDirection;
+    nulls?: Nullable<SortNulls>;
+}
+
 export interface UserDatabaseFilter {
     and?: Nullable<UserDatabaseFilter[]>;
     or?: Nullable<UserDatabaseFilter[]>;
@@ -802,6 +820,43 @@ export interface DeleteOneMenuInput {
     id: string;
 }
 
+export interface CreateOneOrderInput {
+    order: CreateOrderInput;
+}
+
+export interface CreateOrderInput {
+    address: string;
+    total?: Nullable<number>;
+    state: string;
+    items: CreateOrderItemInput[];
+}
+
+export interface CreateOrderItemInput {
+    name: string;
+    quantity: number;
+}
+
+export interface UpdateOneOrderInput {
+    id: string;
+    update: UpdateOrderInput;
+}
+
+export interface UpdateOrderInput {
+    address?: Nullable<string>;
+    total?: Nullable<number>;
+    state?: Nullable<string>;
+    items?: Nullable<UpdateOrderItemInput[]>;
+}
+
+export interface UpdateOrderItemInput {
+    name?: Nullable<string>;
+    quantity?: Nullable<number>;
+}
+
+export interface DeleteOneOrderInput {
+    id: string;
+}
+
 export interface CreateOneUserDatabaseInput {
     userDatabase: CreateUserDatabase;
 }
@@ -1030,6 +1085,20 @@ export interface AccountCredential {
     authExpired: boolean;
 }
 
+export interface OrderItem {
+    name: string;
+    quantity: number;
+}
+
+export interface Order {
+    id: string;
+    createdAt: DateTime;
+    address: string;
+    total: number;
+    state: string;
+    items: OrderItem[];
+}
+
 export interface UserDatabase {
     id: string;
     createdAt: DateTime;
@@ -1332,6 +1401,25 @@ export interface MenuConnection {
     edges: MenuEdge[];
 }
 
+export interface OrderDeleteResponse {
+    id?: Nullable<string>;
+    createdAt?: Nullable<DateTime>;
+    address?: Nullable<string>;
+    total?: Nullable<number>;
+    state?: Nullable<string>;
+    items?: Nullable<OrderItem[]>;
+}
+
+export interface OrderEdge {
+    node: Order;
+    cursor: ConnectionCursor;
+}
+
+export interface OrderConnection {
+    pageInfo: PageInfo;
+    edges: OrderEdge[];
+}
+
 export interface WorkflowTriggerDeleteResponse {
     id?: Nullable<string>;
     createdAt?: Nullable<DateTime>;
@@ -1523,6 +1611,8 @@ export interface IQuery {
     campaigns(paging?: Nullable<CursorPaging>, filter?: Nullable<CampaignFilter>, sorting?: Nullable<CampaignSort[]>): CampaignConnection | Promise<CampaignConnection>;
     menu(id: string): Menu | Promise<Menu>;
     menus(paging?: Nullable<CursorPaging>, filter?: Nullable<MenuFilter>, sorting?: Nullable<MenuSort[]>): MenuConnection | Promise<MenuConnection>;
+    order(id: string): Order | Promise<Order>;
+    orders(paging?: Nullable<CursorPaging>, filter?: Nullable<OrderFilter>, sorting?: Nullable<OrderSort[]>): OrderConnection | Promise<OrderConnection>;
     contractSchema(chainId: number, address: string, type: string): ContractSchema | Promise<ContractSchema>;
     asyncSchemas(integrationId: string, accountCredentialId: string, names: string[], inputs?: Nullable<JSONObject>, integrationTriggerId?: Nullable<string>, integrationActionId?: Nullable<string>): AsyncSchema | Promise<AsyncSchema>;
     manyAsyncSchemas(asyncSchemaInputs: JSONObject[]): AsyncSchema | Promise<AsyncSchema>;
@@ -1575,6 +1665,9 @@ export interface IMutation {
     createOneMenu(input: CreateOneMenuInput): Menu | Promise<Menu>;
     updateOneMenu(input: UpdateOneMenuInput): Menu | Promise<Menu>;
     deleteOneMenu(input: DeleteOneMenuInput): MenuDeleteResponse | Promise<MenuDeleteResponse>;
+    createOneOrder(input: CreateOneOrderInput): Order | Promise<Order>;
+    updateOneOrder(input: UpdateOneOrderInput): Order | Promise<Order>;
+    deleteOneOrder(input: DeleteOneOrderInput): OrderDeleteResponse | Promise<OrderDeleteResponse>;
     createOneUserDatabase(input: CreateOneUserDatabaseInput): UserDatabase | Promise<UserDatabase>;
     updateOneUserDatabase(input: UpdateOneUserDatabaseInput): UserDatabase | Promise<UserDatabase>;
     deleteOneUserDatabase(input: DeleteOneUserDatabaseInput): UserDatabaseDeleteResponse | Promise<UserDatabaseDeleteResponse>;