WIP

Author: thomassnielsen

packages/server/src/api/rest/index.ts

@@ -716,6 +716,14 @@ class RequestHandler extends APIHandlerBase {
             body = SuperJSON.deserialize({ json: body, meta: body.meta.serialization });
         }
 
+        let method: 'create' | 'update' | 'upsert' = mode;
+        let matchFields = [];
+
+        if (body.meta?.operation === 'upsert' && body.meta?.matchFields.length) {
+            method = 'upsert';
+            matchFields = body.meta.matchFields;
+        }
+
         const parsed = this.createUpdatePayloadSchema.parse(body);
         const attributes: any = parsed.data.attributes;
 
@@ -740,7 +748,7 @@ class RequestHandler extends APIHandlerBase {
             }
         }
 
-        return { attributes, relationships: parsed.data.relationships };
+        return { attributes, relationships: parsed.data.relationships, method, matchFields };
     }
 
     private async processCreate(
@@ -756,53 +764,63 @@ class RequestHandler extends APIHandlerBase {
             return this.makeUnsupportedModelError(type);
         }
 
-        const { error, attributes, relationships } = this.processRequestBody(type, requestBody, zodSchemas, 'create');
+        const { error, attributes, relationships, method, matchFields } = this.processRequestBody(
+            type,
+            requestBody,
+            zodSchemas,
+            'create'
+        );
 
         if (error) {
             return error;
         }
 
-        const createPayload: any = { data: { ...attributes } };
+        let entity: any;
+        if (method === 'upsert') {
+            entity = await prisma[type].upsert(createPayload);
+        } else {
+            const createPayload: any = { data: { ...attributes } };
 
-        // turn relationship payload into Prisma connect objects
-        if (relationships) {
-            for (const [key, data] of Object.entries<any>(relationships)) {
-                if (!data?.data) {
-                    return this.makeError('invalidRelationData');
-                }
+            // turn relationship payload into Prisma connect objects
+            if (relationships) {
+                for (const [key, data] of Object.entries<any>(relationships)) {
+                    if (!data?.data) {
+                        return this.makeError('invalidRelationData');
+                    }
 
-                const relationInfo = typeInfo.relationships[key];
-                if (!relationInfo) {
-                    return this.makeUnsupportedRelationshipError(type, key, 400);
-                }
+                    const relationInfo = typeInfo.relationships[key];
+                    if (!relationInfo) {
+                        return this.makeUnsupportedRelationshipError(type, key, 400);
+                    }
 
-                if (relationInfo.isCollection) {
-                    createPayload.data[key] = {
-                        connect: enumerate(data.data).map((item: any) =>
-                            this.makeIdConnect(relationInfo.idFields, item.id)
-                        ),
-                    };
-                } else {
-                    if (typeof data.data !== 'object') {
-                        return this.makeError('invalidRelationData');
+                    if (relationInfo.isCollection) {
+                        createPayload.data[key] = {
+                            connect: enumerate(data.data).map((item: any) =>
+                                this.makeIdConnect(relationInfo.idFields, item.id)
+                            ),
+                        };
+                    } else {
+                        if (typeof data.data !== 'object') {
+                            return this.makeError('invalidRelationData');
+                        }
+                        createPayload.data[key] = {
+                            connect: this.makeIdConnect(relationInfo.idFields, data.data.id),
+                        };
                     }
-                    createPayload.data[key] = {
-                        connect: this.makeIdConnect(relationInfo.idFields, data.data.id),
+
+                    // make sure ID fields are included for result serialization
+                    createPayload.include = {
+                        ...createPayload.include,
+                        [key]: { select: { [this.makePrismaIdKey(relationInfo.idFields)]: true } },
                     };
                 }
-
-                // make sure ID fields are included for result serialization
-                createPayload.include = {
-                    ...createPayload.include,
-                    [key]: { select: { [this.makePrismaIdKey(relationInfo.idFields)]: true } },
-                };
             }
-        }
 
-        // include IDs of relation fields so that they can be serialized.
-        this.includeRelationshipIds(type, createPayload, 'include');
+            // include IDs of relation fields so that they can be serialized.
+            this.includeRelationshipIds(type, createPayload, 'include');
 
-        const entity = await prisma[type].create(createPayload);
+            entity = await prisma[type].create(createPayload);
+        }
         return {
             status: 201,
             body: await this.serializeItems(type, entity),