Merge pull request #10 from anran758/develop

Enhance io operations: support for bulk operations and improved type handling

apps/faas-demo/package.json

@@ -20,7 +20,7 @@
     "upload": "mincloudx faas upload",
     "deploy": "mincloudx faas deploy",
     "debug": "mincloudx faas debug",
-    "refresh": "mincloudx type"
+    "refresh": "mincloudx type --pull"
   },
   "bugs": {
     "url": "https://github.com/anran758/mincloudx/issues"

apps/faas-demo/src/function/channel/channelDelete.ts

@@ -7,10 +7,8 @@ interface EventParams {
 
 export default createFaas<EventParams>(async function main(event) {
   const { id } = event.data;
-  // const result = await io.channel.delete(id);
+  const result = await io.channel.delete(id);
 
-  const query = io.getQuery({ id });
-  const result = await io.channel.delete(query);
   console.log('delete result:', result);
 
   return result;

apps/faas-demo/src/function/test/testOperationCount.ts

@@ -0,0 +1,13 @@
+import { createFaas } from '@mincloudx/faas';
+import io from '@/io';
+
+export default createFaas(async function main() {
+  const query = io.getQuery({
+    description: 'This is description.',
+  });
+  const count = await io.product.count(query);
+
+  console.log('count: ', count);
+
+  return { count };
+});

apps/faas-demo/src/function/test/testOperationCreateMany.ts

@@ -0,0 +1,37 @@
+import { createFaas } from '@mincloudx/faas';
+import io from '@/io';
+
+import { getCurrentDate } from '@/utils';
+
+function generatorMockData() {
+  const rawData = {
+    name: `新书本-${getCurrentDate()}`,
+    cover:
+      'https://cloud-minapp-47549.cloud.ifanrusercontent.com/1rmlh9degSiaF4ua.jpg',
+    description: 'testOperationCreateMany create.',
+  };
+
+  return Array(6)
+    .fill(0)
+    .map((_, i) => {
+      return {
+        ...rawData,
+        name: `${rawData.name}_${i}`,
+      };
+    });
+}
+export default createFaas(async function main() {
+  const list = generatorMockData();
+
+  const {
+    operation_result: result,
+    succeed,
+    total_count,
+  } = await io.product.createMany(list);
+
+  console.log('result:', result);
+  console.log('succeed: ', succeed);
+  console.log('total: ', total_count);
+
+  return result;
+});

apps/faas-demo/src/function/test/testOperationDeleteMany.ts

@@ -0,0 +1,17 @@
+import { createFaas } from '@mincloudx/faas';
+import io from '@/io';
+
+export default createFaas(async function main() {
+  const result = await io.product.deleteMany(io.query, {
+    limit: 2,
+  });
+  console.log(
+    'result: ',
+    result.succeed,
+    result.offset,
+    result.limit,
+    result.next,
+  );
+
+  return result;
+});

apps/faas-demo/src/function/test/testOperationFindList.ts

@@ -0,0 +1,14 @@
+import { createFaas } from '@mincloudx/faas';
+import io from '@/io';
+
+export default createFaas(async function main() {
+  const query = io.getQuery({
+    description: 'This is description.',
+  });
+  const result = await io.product.find(query, {
+    select: ['id', 'name', 'description'],
+    plain: true,
+  });
+
+  return result;
+});

apps/faas-demo/src/function/test/testOperationUpdateMany.ts

@@ -0,0 +1,17 @@
+import { createFaas } from '@mincloudx/faas';
+import io from '@/io';
+
+export default createFaas(async function main() {
+  const list = await io.product.updateMany({
+    query: io.getQuery({
+      created_at: 1711691446,
+    }),
+    data: {
+      description: `update date: ${new Date()}`,
+    },
+  });
+
+  console.log('result:', list);
+
+  return list;
+});

apps/faas-demo/src/io/index.ts

@@ -1,5 +1,5 @@
 import { createIo } from '@mincloudx/io';
 
 export default createIo({
-  tables: ['channel'],
+  tables: ['channel', 'product'],
 });

apps/faas-demo/src/utils/index.ts

@@ -0,0 +1,20 @@
+export function getCurrentDate() {
+  const now = new Date();
+
+  // 分别获取日期和时间字符串
+  const dateString = now
+    .toLocaleDateString('zh-CN', {
+      year: 'numeric',
+      month: '2-digit',
+      day: '2-digit',
+    })
+    .replace(/\//g, '-');
+
+  const timeString = now.toLocaleTimeString('zh-CN', {
+    hour: '2-digit',
+    minute: '2-digit',
+    hour12: false, // 使用24小时制
+  });
+
+  return `${dateString} ${timeString}`;
+}