@effect/sql - npm Package Compare versions

Comparing version 0.11.1 to 0.11.2

dist/cjs/Migrator/FileSystem.js

@@ -27,2 +27,3 @@ "use strict";
   onSome: ([basename, id, name]) => [[Number(id), name, Effect.promise(() => import( /* @vite-ignore */
+  /* webpackIgnore: true */
   `${directory}/${basename}`))]]
@@ -29,0 +30,0 @@ })).sort(([a], [b]) => a - b)));

dist/cjs/Migrator/FileSystem.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"FileSystem.js","names":["_FileSystem","require","Effect","_interopRequireWildcard","Option","_Migrator","_getRequireWildcardCache","e","WeakMap","r","t","__esModule","default","has","get","n","__proto__","a","Object","defineProperty","getOwnPropertyDescriptor","u","hasOwnProperty","call","i","set","fromFileSystem","directory","FileSystem","pipe","flatMap","FS","readDirectory","mapError","error","MigrationError","reason","message","map","files","file","fromNullable","match","onNone","onSome","basename","id","name","Number","promise","sort","b","exports"],"sources":["../../../src/Migrator/FileSystem.ts"],"sourcesContent":[null],"mappings":";;;;;;AAGA,IAAAA,WAAA,GAAAC,OAAA;AACA,IAAAC,MAAA,GAAAC,uBAAA,CAAAF,OAAA;AACA,IAAAG,MAAA,GAAAD,uBAAA,CAAAF,OAAA;AAEA,IAAAI,SAAA,GAAAJ,OAAA;AAA+C,SAAAK,yBAAAC,CAAA,6BAAAC,OAAA,mBAAAC,CAAA,OAAAD,OAAA,IAAAE,CAAA,OAAAF,OAAA,YAAAF,wBAAA,YAAAA,CAAAC,CAAA,WAAAA,CAAA,GAAAG,CAAA,GAAAD,CAAA,KAAAF,CAAA;AAAA,SAAAJ,wBAAAI,CAAA,EAAAE,CAAA,SAAAA,CAAA,IAAAF,CAAA,IAAAA,CAAA,CAAAI,UAAA,SAAAJ,CAAA,eAAAA,CAAA,uBAAAA,CAAA,yBAAAA,CAAA,WAAAK,OAAA,EAAAL,CAAA,QAAAG,CAAA,GAAAJ,wBAAA,CAAAG,CAAA,OAAAC,CAAA,IAAAA,CAAA,CAAAG,GAAA,CAAAN,CAAA,UAAAG,CAAA,CAAAI,GAAA,CAAAP,CAAA,OAAAQ,CAAA,KAAAC,SAAA,UAAAC,CAAA,GAAAC,MAAA,CAAAC,cAAA,IAAAD,MAAA,CAAAE,wBAAA,WAAAC,CAAA,IAAAd,CAAA,oBAAAc,CAAA,OAAAC,cAAA,CAAAC,IAAA,CAAAhB,CAAA,EAAAc,CAAA,SAAAG,CAAA,GAAAP,CAAA,GAAAC,MAAA,CAAAE,wBAAA,CAAAb,CAAA,EAAAc,CAAA,UAAAG,CAAA,KAAAA,CAAA,CAAAV,GAAA,IAAAU,CAAA,CAAAC,GAAA,IAAAP,MAAA,CAAAC,cAAA,CAAAJ,CAAA,EAAAM,CAAA,EAAAG,CAAA,IAAAT,CAAA,CAAAM,CAAA,IAAAd,CAAA,CAAAc,CAAA,YAAAN,CAAA,CAAAH,OAAA,GAAAL,CAAA,EAAAG,CAAA,IAAAA,CAAA,CAAAe,GAAA,CAAAlB,CAAA,EAAAQ,CAAA,GAAAA,CAAA;AAP/C;;;;AASA;;;;AAIO,MAAMW,cAAc,GAAIC,SAAiB,IAC9CC,sBAAU,CAACC,IAAI,CACb3B,MAAM,CAAC4B,OAAO,CAAEC,EAAE,IAAKA,EAAE,CAACC,aAAa,CAACL,SAAS,CAAC,CAAC,EACnDzB,MAAM,CAAC+B,QAAQ,CAAEC,KAAK,IAAK,IAAIC,wBAAc,CAAC;EAAEC,MAAM,EAAE,QAAQ;EAAEC,OAAO,EAAEH,KAAK,CAACG;AAAO,CAAE,CAAC,CAAC,EAC5FnC,MAAM,CAACoC,GAAG,CAAEC,KAAK,IACfA,KAAK,CACFD,GAAG,CAAEE,IAAI,IAAKpC,MAAM,CAACqC,YAAY,CAACD,IAAI,CAACE,KAAK,CAAC,mCAAmC,CAAC,CAAC,CAAC,CACnFZ,OAAO,CACN1B,MAAM,CAACsC,KAAK,CAAC;EACXC,MAAM,EAAEA,CAAA,KAAM,EAAE;EAChBC,MAAM,EAAEA,CAAC,CAACC,QAAQ,EAAEC,EAAE,EAAEC,IAAI,CAAC,KAC3B,CACE,CACEC,MAAM,CAACF,EAAE,CAAC,EACVC,IAAI,EACJ7C,MAAM,CAAC+C,OAAO,CACZ,MACE,MAAM,EACJ;EACA,GAAGtB,SAAS,IAAIkB,QAAQ,EAAE,CAC3B,CACJ,CACF;CAEN,CAAC,CACH,CACAK,IAAI,CAAC,CAAC,CAACjC,CAAC,CAAC,EAAE,CAACkC,CAAC,CAAC,KAAKlC,CAAC,GAAGkC,CAAC,CAAC,CAC7B,CACF;AAAAC,OAAA,CAAA1B,cAAA,GAAAA,cAAA","ignoreList":[]}
+{"version":3,"file":"FileSystem.js","names":["_FileSystem","require","Effect","_interopRequireWildcard","Option","_Migrator","_getRequireWildcardCache","e","WeakMap","r","t","__esModule","default","has","get","n","__proto__","a","Object","defineProperty","getOwnPropertyDescriptor","u","hasOwnProperty","call","i","set","fromFileSystem","directory","FileSystem","pipe","flatMap","FS","readDirectory","mapError","error","MigrationError","reason","message","map","files","file","fromNullable","match","onNone","onSome","basename","id","name","Number","promise","sort","b","exports"],"sources":["../../../src/Migrator/FileSystem.ts"],"sourcesContent":[null],"mappings":";;;;;;AAGA,IAAAA,WAAA,GAAAC,OAAA;AACA,IAAAC,MAAA,GAAAC,uBAAA,CAAAF,OAAA;AACA,IAAAG,MAAA,GAAAD,uBAAA,CAAAF,OAAA;AAEA,IAAAI,SAAA,GAAAJ,OAAA;AAA+C,SAAAK,yBAAAC,CAAA,6BAAAC,OAAA,mBAAAC,CAAA,OAAAD,OAAA,IAAAE,CAAA,OAAAF,OAAA,YAAAF,wBAAA,YAAAA,CAAAC,CAAA,WAAAA,CAAA,GAAAG,CAAA,GAAAD,CAAA,KAAAF,CAAA;AAAA,SAAAJ,wBAAAI,CAAA,EAAAE,CAAA,SAAAA,CAAA,IAAAF,CAAA,IAAAA,CAAA,CAAAI,UAAA,SAAAJ,CAAA,eAAAA,CAAA,uBAAAA,CAAA,yBAAAA,CAAA,WAAAK,OAAA,EAAAL,CAAA,QAAAG,CAAA,GAAAJ,wBAAA,CAAAG,CAAA,OAAAC,CAAA,IAAAA,CAAA,CAAAG,GAAA,CAAAN,CAAA,UAAAG,CAAA,CAAAI,GAAA,CAAAP,CAAA,OAAAQ,CAAA,KAAAC,SAAA,UAAAC,CAAA,GAAAC,MAAA,CAAAC,cAAA,IAAAD,MAAA,CAAAE,wBAAA,WAAAC,CAAA,IAAAd,CAAA,oBAAAc,CAAA,OAAAC,cAAA,CAAAC,IAAA,CAAAhB,CAAA,EAAAc,CAAA,SAAAG,CAAA,GAAAP,CAAA,GAAAC,MAAA,CAAAE,wBAAA,CAAAb,CAAA,EAAAc,CAAA,UAAAG,CAAA,KAAAA,CAAA,CAAAV,GAAA,IAAAU,CAAA,CAAAC,GAAA,IAAAP,MAAA,CAAAC,cAAA,CAAAJ,CAAA,EAAAM,CAAA,EAAAG,CAAA,IAAAT,CAAA,CAAAM,CAAA,IAAAd,CAAA,CAAAc,CAAA,YAAAN,CAAA,CAAAH,OAAA,GAAAL,CAAA,EAAAG,CAAA,IAAAA,CAAA,CAAAe,GAAA,CAAAlB,CAAA,EAAAQ,CAAA,GAAAA,CAAA;AAP/C;;;;AASA;;;;AAIO,MAAMW,cAAc,GAAIC,SAAiB,IAC9CC,sBAAU,CAACC,IAAI,CACb3B,MAAM,CAAC4B,OAAO,CAAEC,EAAE,IAAKA,EAAE,CAACC,aAAa,CAACL,SAAS,CAAC,CAAC,EACnDzB,MAAM,CAAC+B,QAAQ,CAAEC,KAAK,IAAK,IAAIC,wBAAc,CAAC;EAAEC,MAAM,EAAE,QAAQ;EAAEC,OAAO,EAAEH,KAAK,CAACG;AAAO,CAAE,CAAC,CAAC,EAC5FnC,MAAM,CAACoC,GAAG,CAAEC,KAAK,IACfA,KAAK,CACFD,GAAG,CAAEE,IAAI,IAAKpC,MAAM,CAACqC,YAAY,CAACD,IAAI,CAACE,KAAK,CAAC,mCAAmC,CAAC,CAAC,CAAC,CACnFZ,OAAO,CACN1B,MAAM,CAACsC,KAAK,CAAC;EACXC,MAAM,EAAEA,CAAA,KAAM,EAAE;EAChBC,MAAM,EAAEA,CAAC,CAACC,QAAQ,EAAEC,EAAE,EAAEC,IAAI,CAAC,KAC3B,CACE,CACEC,MAAM,CAACF,EAAE,CAAC,EACVC,IAAI,EACJ7C,MAAM,CAAC+C,OAAO,CACZ,MACE,MAAM,EACJ;EACA;EACA,GAAGtB,SAAS,IAAIkB,QAAQ,EAAE,CAC3B,CACJ,CACF;CAEN,CAAC,CACH,CACAK,IAAI,CAAC,CAAC,CAACjC,CAAC,CAAC,EAAE,CAACkC,CAAC,CAAC,KAAKlC,CAAC,GAAGkC,CAAC,CAAC,CAC7B,CACF;AAAAC,OAAA,CAAA1B,cAAA,GAAAA,cAAA","ignoreList":[]}

dist/cjs/Model.js

@@ -302,6 +302,11 @@ "use strict";
   const idSchema = Model.fields[options.idColumn];
+  const idColumn = options.idColumn;
   const insertSchema = SqlSchema.single({
     Request: Model.insert,
     Result: Model,
-    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    execute: request => sql.onDialectOrElse({
+      mysql: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request)};
+select * from ${sql(options.tableName)} where ${sql(idColumn)} = LAST_INSERT_ID();`.unprepared.pipe(Effect.map(([, results]) => results)),
+      orElse: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    })
   });
@@ -314,6 +319,19 @@ const insert = insert => insertSchema(insert).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.insert`, {
   }));
+  const insertVoidSchema = SqlSchema.void({
+    Request: Model.insert,
+    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request)}`
+  });
+  const insertVoid = insert => insertVoidSchema(insert).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.insertVoid`, {
+    captureStackTrace: false,
+    attributes: {
+      insert
+    }
+  }));
   const updateSchema = SqlSchema.single({
     Request: Model.update,
     Result: Model,
-    execute: request => sql`update ${sql(options.tableName)} set ${sql.update(request, [options.idColumn])} where ${sql(options.idColumn)} = ${sql(request[options.idColumn])} returning *`
+    execute: request => sql.onDialectOrElse({
+      mysql: () => sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${request[idColumn]}`.raw.pipe(Effect.zipRight(sql`select * from ${sql(options.tableName)} where ${sql(options.idColumn)} = ${request[idColumn]}`), sql.withTransaction),
+      orElse: () => sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${request[idColumn]} returning *`
+    })
   });
@@ -326,6 +344,16 @@ const update = update => updateSchema(update).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.update`, {
   }));
+  const updateVoidSchema = SqlSchema.void({
+    Request: Model.update,
+    execute: request => sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${request[idColumn]}`
+  });
+  const updateVoid = update => updateVoidSchema(update).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.updateVoid`, {
+    captureStackTrace: false,
+    attributes: {
+      update
+    }
+  }));
   const findByIdSchema = SqlSchema.findOne({
     Request: idSchema,
     Result: Model,
-    execute: id => sql`select * from ${sql(options.tableName)} where ${sql(options.idColumn)} = ${id}`
+    execute: id => sql`select * from ${sql(options.tableName)} where ${sql(idColumn)} = ${id}`
   });
@@ -340,3 +368,3 @@ const findById = id => findByIdSchema(id).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.findById`, {
     Request: idSchema,
-    execute: id => sql`delete from ${sql(options.tableName)} where ${sql(options.idColumn)} = ${id}`
+    execute: id => sql`delete from ${sql(options.tableName)} where ${sql(idColumn)} = ${id}`
   });
@@ -351,3 +379,5 @@ const delete_ = id => deleteSchema(id).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.delete`, {
     insert,
+    insertVoid,
     update,
+    updateVoid,
     findById,
@@ -367,6 +397,13 @@ delete: delete_
   const idSchema = Model.fields[options.idColumn];
+  const idColumn = options.idColumn;
   const insertResolver = yield* SqlResolver.ordered(`${options.spanPrefix}/insert`, {
     Request: Model.insert,
     Result: Model,
-    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    execute: request => sql.onDialectOrElse({
+      mysql: () => Effect.forEach(request, request => sql`insert into ${sql(options.tableName)} ${sql.insert(request)};
+select * from ${sql(options.tableName)} where ${sql(idColumn)} = LAST_INSERT_ID();`.unprepared.pipe(Effect.map(([, results]) => results[0])), {
+        concurrency: 10
+      }),
+      orElse: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    })
   });
@@ -384,2 +421,17 @@ const insertLoader = yield* RRX.dataLoader(insertResolver, {
   }));
+  const insertVoidResolver = yield* SqlResolver.void(`${options.spanPrefix}/insertVoid`, {
+    Request: Model.insert,
+    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request)}`
+  });
+  const insertVoidLoader = yield* RRX.dataLoader(insertVoidResolver, {
+    window: options.window,
+    maxBatchSize: options.maxBatchSize
+  });
+  const insertVoidExecute = insertVoidResolver.makeExecute(insertVoidLoader);
+  const insertVoid = insert => insertVoidExecute(insert).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.insertVoid`, {
+    captureStackTrace: false,
+    attributes: {
+      insert
+    }
+  }));
   const findByIdResolver = yield* SqlResolver.grouped(`${options.spanPrefix}/findById`, {
@@ -392,5 +444,5 @@ Request: idSchema,
     ResultGroupKey(request) {
-      return request[options.idColumn];
+      return request[idColumn];
     },
-    execute: ids => sql`select * from ${sql(options.tableName)} where ${sql.in(options.idColumn, ids)}`
+    execute: ids => sql`select * from ${sql(options.tableName)} where ${sql.in(idColumn, ids)}`
   });
@@ -410,3 +462,3 @@ const findByIdLoader = yield* RRX.dataLoader(findByIdResolver, {
     Request: idSchema,
-    execute: ids => sql`delete from ${sql(options.tableName)} where ${sql.in(options.idColumn, ids)}`
+    execute: ids => sql`delete from ${sql(options.tableName)} where ${sql.in(idColumn, ids)}`
   });
@@ -426,2 +478,3 @@ const deleteLoader = yield* RRX.dataLoader(deleteResolver, {
     insert,
+    insertVoid,
     findById,
@@ -428,0 +481,0 @@ delete: delete_

dist/cjs/Model.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"Model.js","names":["RRX","_interopRequireWildcard","require","VariantSchema","ParseResult","Schema","DateTime","Effect","Option","_SqlClient","SqlResolver","SqlSchema","_getRequireWildcardCache","e","WeakMap","r","t","__esModule","default","has","get","n","__proto__","a","Object","defineProperty","getOwnPropertyDescriptor","u","hasOwnProperty","call","i","set","Class","Field","FieldExcept","FieldOnly","Struct","Union","extract","fieldEvolve","make","variants","defaultVariant","exports","fields","Override","Generated","schema","select","update","json","GeneratedByApp","insert","Sensitive","FieldOption","OptionFromNullOr","optionalWith","as","jsonCreate","nullable","jsonUpdate","DateTimeFromDate","transform","ValidDateFromSelf","DateTimeUtcFromSelf","decode","unsafeFromDate","encode","toDateUtc","Date","transformOrFail","String","s","_","ast","pipe","map","removeTime","match","onNone","fail","Type","onSome","dt","succeed","formatIsoDate","DateWithNow","Overrideable","generate","now","DateTimeWithNow","formatIso","DateTimeFromDateWithNow","DateFromSelf","DateTimeFromNumberWithNow","Number","toEpochMillis","DateTimeInsert","DateTimeUtc","DateTimeInsertFromDate","DateTimeInsertFromNumber","DateTimeUtcFromNumber","DateTimeUpdate","DateTimeUpdateFromDate","DateTimeUpdateFromNumber","JsonFromString","parsed","parseJson","makeRepository","Model","options","gen","sql","SqlClient","idSchema","idColumn","insertSchema","single","Request","Result","execute","request","tableName","returning","orDie","withSpan","spanPrefix","captureStackTrace","attributes","updateSchema","findByIdSchema","findOne","id","findById","deleteSchema","void","delete_","delete","makeDataLoaders","insertResolver","ordered","insertLoader","dataLoader","window","maxBatchSize","insertExecute","makeExecute","findByIdResolver","grouped","RequestGroupKey","ResultGroupKey","ids","in","findByIdLoader","findByIdExecute","deleteResolver","deleteLoader","deleteExecute"],"sources":["../../src/Model.ts"],"sourcesContent":[null],"mappings":";;;;;;AAGA,IAAAA,GAAA,GAAAC,uBAAA,CAAAC,OAAA;AACA,IAAAC,aAAA,GAAAF,uBAAA,CAAAC,OAAA;AACA,IAAAE,WAAA,GAAAH,uBAAA,CAAAC,OAAA;AACA,IAAAG,MAAA,GAAAJ,uBAAA,CAAAC,OAAA;AAEA,IAAAI,QAAA,GAAAL,uBAAA,CAAAC,OAAA;AAEA,IAAAK,MAAA,GAAAN,uBAAA,CAAAC,OAAA;AACA,IAAAM,MAAA,GAAAP,uBAAA,CAAAC,OAAA;AAEA,IAAAO,UAAA,GAAAP,OAAA;AACA,IAAAQ,WAAA,GAAAT,uBAAA,CAAAC,OAAA;AACA,IAAAS,SAAA,GAAAV,uBAAA,CAAAC,OAAA;AAA2C,SAAAU,yBAAAC,CAAA,6BAAAC,OAAA,mBAAAC,CAAA,OAAAD,OAAA,IAAAE,CAAA,OAAAF,OAAA,YAAAF,wBAAA,YAAAA,CAAAC,CAAA,WAAAA,CAAA,GAAAG,CAAA,GAAAD,CAAA,KAAAF,CAAA;AAAA,SAAAZ,wBAAAY,CAAA,EAAAE,CAAA,SAAAA,CAAA,IAAAF,CAAA,IAAAA,CAAA,CAAAI,UAAA,SAAAJ,CAAA,eAAAA,CAAA,uBAAAA,CAAA,yBAAAA,CAAA,WAAAK,OAAA,EAAAL,CAAA,QAAAG,CAAA,GAAAJ,wBAAA,CAAAG,CAAA,OAAAC,CAAA,IAAAA,CAAA,CAAAG,GAAA,CAAAN,CAAA,UAAAG,CAAA,CAAAI,GAAA,CAAAP,CAAA,OAAAQ,CAAA,KAAAC,SAAA,UAAAC,CAAA,GAAAC,MAAA,CAAAC,cAAA,IAAAD,MAAA,CAAAE,wBAAA,WAAAC,CAAA,IAAAd,CAAA,oBAAAc,CAAA,OAAAC,cAAA,CAAAC,IAAA,CAAAhB,CAAA,EAAAc,CAAA,SAAAG,CAAA,GAAAP,CAAA,GAAAC,MAAA,CAAAE,wBAAA,CAAAb,CAAA,EAAAc,CAAA,UAAAG,CAAA,KAAAA,CAAA,CAAAV,GAAA,IAAAU,CAAA,CAAAC,GAAA,IAAAP,MAAA,CAAAC,cAAA,CAAAJ,CAAA,EAAAM,CAAA,EAAAG,CAAA,IAAAT,CAAA,CAAAM,CAAA,IAAAd,CAAA,CAAAc,CAAA,YAAAN,CAAA,CAAAH,OAAA,GAAAL,CAAA,EAAAG,CAAA,IAAAA,CAAA,CAAAe,GAAA,CAAAlB,CAAA,EAAAQ,CAAA,GAAAA,CAAA;AAf3C;;;;AAiBA,MAAM;EACJW,KAAK;EACLC,KAAK;EACLC,WAAW;EACXC,SAAS;EACTC,MAAM;EACNC,KAAK;EACLC,OAAO;EACPC;AAAW,CACZ,gBAAGpC,aAAa,CAACqC,IAAI,CAAC;EACrBC,QAAQ,EAAE,CAAC,QAAQ,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,EAAE,YAAY,EAAE,YAAY,CAAC;EAC5EC,cAAc,EAAE;CACjB,CAAC;AAAAC,OAAA,CAAAJ,WAAA,GAAAA,WAAA;AAAAI,OAAA,CAAAL,OAAA,GAAAA,OAAA;AAAAK,OAAA,CAAAN,KAAA,GAAAA,KAAA;AAAAM,OAAA,CAAAP,MAAA,GAAAA,MAAA;AAAAO,OAAA,CAAAR,SAAA,GAAAA,SAAA;AAAAQ,OAAA,CAAAT,WAAA,GAAAA,WAAA;AAAAS,OAAA,CAAAV,KAAA,GAAAA,KAAA;AAAAU,OAAA,CAAAX,KAAA,GAAAA,KAAA;AAwHF;;;;AAIO,MAAMY,MAAM,GAAAD,OAAA,CAAAC,MAAA,GAA8EzC,aAAa,CAACyC,MAAM;AAErH;;;;AAIO,MAAMC,QAAQ,GAAAF,OAAA,CAAAE,QAAA,GAA2C1C,aAAa,CAAC0C,QAAQ;AActF;;;;;;;;AAQO,MAAMC,SAAS,GACpBC,MAAS,IAETd,KAAK,CAAC;EACJe,MAAM,EAAED,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAgBJ;;;;;;;;AAAAJ,OAAA,CAAAG,SAAA,GAAAA,SAAA;AAQO,MAAMK,cAAc,GACzBJ,MAAS,IAETd,KAAK,CAAC;EACJe,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAcJ;;;;;;;AAAAJ,OAAA,CAAAQ,cAAA,GAAAA,cAAA;AAOO,MAAME,SAAS,GACpBN,MAAS,IAETd,KAAK,CAAC;EACJe,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF;CACT,CAAC;AAsBJ;;;;;;;;;AAAAJ,OAAA,CAAAU,SAAA,GAAAA,SAAA;AASO,MAAMC,WAAW,GAAAX,OAAA,CAAAW,WAAA,gBAWdf,WAAW,CAAC;EAClBS,MAAM,EAAE3C,MAAM,CAACkD,gBAAgB;EAC/BH,MAAM,EAAE/C,MAAM,CAACkD,gBAAgB;EAC/BN,MAAM,EAAE5C,MAAM,CAACkD,gBAAgB;EAC/BL,IAAI,eAAE7C,MAAM,CAACmD,YAAY,CAAC;IAAEC,EAAE,EAAE;EAAQ,CAAE,CAAC;EAC3CC,UAAU,eAAErD,MAAM,CAACmD,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE,CAAC;EACjEC,UAAU,eAAEvD,MAAM,CAACmD,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE;CACjE,CAAQ;AAaX;;;;AAIO,MAAME,gBAAgB,GAAAlB,OAAA,CAAAkB,gBAAA,gBAAqBxD,MAAM,CAACyD,SAAS,CAChEzD,MAAM,CAAC0D,iBAAiB,EACxB1D,MAAM,CAAC2D,mBAAmB,EAC1B;EACEC,MAAM,EAAE3D,QAAQ,CAAC4D,cAAc;EAC/BC,MAAM,EAAE7D,QAAQ,CAAC8D;CAClB,CACF;AAQD;;;;;;;AAOO,MAAMC,IAAI,GAAA1B,OAAA,CAAA0B,IAAA,gBAAShE,MAAM,CAACiE,eAAe,CAC9CjE,MAAM,CAACkE,MAAM,EACblE,MAAM,CAAC2D,mBAAmB,EAC1B;EACEC,MAAM,EAAEA,CAACO,CAAC,EAAEC,CAAC,EAAEC,GAAG,KAChBpE,QAAQ,CAACkC,IAAI,CAACgC,CAAC,CAAC,CAACG,IAAI,CACnBnE,MAAM,CAACoE,GAAG,CAACtE,QAAQ,CAACuE,UAAU,CAAC,EAC/BrE,MAAM,CAACsE,KAAK,CAAC;IACXC,MAAM,EAAEA,CAAA,KAAM3E,WAAW,CAAC4E,IAAI,CAAC,IAAI5E,WAAW,CAAC6E,IAAI,CAACP,GAAG,EAAEF,CAAC,CAAC,CAAC;IAC5DU,MAAM,EAAGC,EAAE,IAAK/E,WAAW,CAACgF,OAAO,CAACD,EAAE;GACvC,CAAC,CACH;EACHhB,MAAM,EAAGgB,EAAE,IAAK/E,WAAW,CAACgF,OAAO,CAAC9E,QAAQ,CAAC+E,aAAa,CAACF,EAAE,CAAC;CAC/D,CACF;AAED;;;;AAIO,MAAMG,WAAW,GAAA3C,OAAA,CAAA2C,WAAA,gBAAGnF,aAAa,CAACoF,YAAY,CAAClB,IAAI,EAAEhE,MAAM,CAAC2D,mBAAmB,EAAE;EACtFwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAACuE,UAAU,CAAC;IAC3DK,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAACuE,UAAU,CAACM,EAAE,CAAC;GACvD;CACF,CAAC;AAEF;;;;AAIO,MAAMO,eAAe,GAAA/C,OAAA,CAAA+C,eAAA,gBAAGvF,aAAa,CAACoF,YAAY,CAAClF,MAAM,CAACkE,MAAM,EAAElE,MAAM,CAAC2D,mBAAmB,EAAE;EACnGwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAACqF,SAAS,CAAC;IAC1DT,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAACqF,SAAS,CAACR,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIO,MAAMS,uBAAuB,GAAAjD,OAAA,CAAAiD,uBAAA,gBAAGzF,aAAa,CAACoF,YAAY,CAAClF,MAAM,CAACwF,YAAY,EAAExF,MAAM,CAAC2D,mBAAmB,EAAE;EACjHwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAAC8D,SAAS,CAAC;IAC1Dc,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAAC8D,SAAS,CAACe,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIO,MAAMW,yBAAyB,GAAAnD,OAAA,CAAAmD,yBAAA,gBAAG3F,aAAa,CAACoF,YAAY,CAAClF,MAAM,CAAC0F,MAAM,EAAE1F,MAAM,CAAC2D,mBAAmB,EAAE;EAC7GwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAAC0F,aAAa,CAAC;IAC9Dd,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAAC0F,aAAa,CAACb,EAAE,CAAC;GAC1D;CACF,CAAC;AAcF;;;;;;;;;AASO,MAAMc,cAAc,GAAAtD,OAAA,CAAAsD,cAAA,gBAAmBhE,KAAK,CAAC;EAClDe,MAAM,EAAE3C,MAAM,CAAC6F,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBxC,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAcF;;;;;;;;;AASO,MAAMC,sBAAsB,GAAAxD,OAAA,CAAAwD,sBAAA,gBAA2BlE,KAAK,CAAC;EAClEe,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B1C,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAcF;;;;;;;;;AASO,MAAME,wBAAwB,GAAAzD,OAAA,CAAAyD,wBAAA,gBAA6BnE,KAAK,CAAC;EACtEe,MAAM,EAAE3C,MAAM,CAACgG,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC5C,IAAI,EAAE7C,MAAM,CAACgG;CACd,CAAC;AAeF;;;;;;;;;;AAUO,MAAMC,cAAc,GAAA3D,OAAA,CAAA2D,cAAA,gBAAmBrE,KAAK,CAAC;EAClDe,MAAM,EAAE3C,MAAM,CAAC6F,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBzC,MAAM,EAAEyC,eAAe;EACvBxC,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAeF;;;;;;;;;;AAUO,MAAMK,sBAAsB,GAAA5D,OAAA,CAAA4D,sBAAA,gBAA2BtE,KAAK,CAAC;EAClEe,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B3C,MAAM,EAAE2C,uBAAuB;EAC/B1C,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAeF;;;;;;;;;;AAUO,MAAMM,wBAAwB,GAAA7D,OAAA,CAAA6D,wBAAA,gBAA6BvE,KAAK,CAAC;EACtEe,MAAM,EAAE3C,MAAM,CAACgG,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC7C,MAAM,EAAE6C,yBAAyB;EACjC5C,IAAI,EAAE7C,MAAM,CAACgG;CACd,CAAC;AAkBF;;;;;;;;AAQO,MAAMI,cAAc,GACzB1D,MAAS,IACY;EACrB,MAAM2D,MAAM,GAAGrG,MAAM,CAACsG,SAAS,CAAC5D,MAAa,CAAC;EAC9C,OAAOd,KAAK,CAAC;IACXe,MAAM,EAAE0D,MAAM;IACdtD,MAAM,EAAEsD,MAAM;IACdzD,MAAM,EAAEyD,MAAM;IACdxD,IAAI,EAAEH,MAAM;IACZW,UAAU,EAAEX,MAAM;IAClBa,UAAU,EAAEb;GACb,CAAQ;AACX,CAAC;AAED;;;;;;AAAAJ,OAAA,CAAA8D,cAAA,GAAAA,cAAA;AAMO,MAAMG,cAAc,GAAGA,CAG5BC,KAAQ,EAAEC,OAIX,KAkBCvG,MAAM,CAACwG,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOC,oBAAS;EAC5B,MAAMC,QAAQ,GAAGL,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACK,QAAQ,CAAsB;EAEpE,MAAMC,YAAY,GAAGzG,SAAS,CAAC0G,MAAM,CAAC;IACpCC,OAAO,EAAET,KAAK,CAACzD,MAAM;IACrBmE,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGC,OAAO,IAAKT,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACY,SAAS,CAAC,IAAIV,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC,CAACE,SAAS,CAAC,GAAG,CAAC;GACrG,CAAC;EACF,MAAMvE,MAAM,GACVA,MAA2B,IAE3BgE,YAAY,CAAChE,MAAM,CAAC,CAACuB,IAAI,CACvBpE,MAAM,CAACqH,KAAK,EACZrH,MAAM,CAACsH,QAAQ,CAAC,GAAGf,OAAO,CAACgB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAE5E;IAAM;GACrB,CAAC,CACI;EAEV,MAAM6E,YAAY,GAAGtH,SAAS,CAAC0G,MAAM,CAAC;IACpCC,OAAO,EAAET,KAAK,CAAC5D,MAAM;IACrBsE,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGC,OAAO,IACfT,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACY,SAAS,CAAC,QAAQV,GAAG,CAAC/D,MAAM,CAACwE,OAAO,EAAE,CAACX,OAAO,CAACK,QAAQ,CAAC,CAAC,UAChFH,GAAG,CAACF,OAAO,CAACK,QAAkB,CAChC,MAAMH,GAAG,CAACS,OAAO,CAACX,OAAO,CAACK,QAAQ,CAAC,CAAC;GACvC,CAAC;EACF,MAAMlE,MAAM,GACVA,MAA2B,IAE3BgF,YAAY,CAAChF,MAAM,CAAC,CAAC0B,IAAI,CACvBpE,MAAM,CAACqH,KAAK,EACZrH,MAAM,CAACsH,QAAQ,CAAC,GAAGf,OAAO,CAACgB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAE/E;IAAM;GACrB,CAAC,CACI;EAEV,MAAMiF,cAAc,GAAGvH,SAAS,CAACwH,OAAO,CAAC;IACvCb,OAAO,EAAEJ,QAAQ;IACjBK,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGY,EAAE,IAAKpB,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACY,SAAS,CAAC,UAAUV,GAAG,CAACF,OAAO,CAACK,QAAkB,CAAC,MAAMiB,EAAE;GAC7G,CAAC;EACF,MAAMC,QAAQ,GACZD,EAAuC,IAEvCF,cAAc,CAACE,EAAE,CAAC,CAACzD,IAAI,CACrBpE,MAAM,CAACqH,KAAK,EACZrH,MAAM,CAACsH,QAAQ,CAAC,GAAGf,OAAO,CAACgB,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,MAAME,YAAY,GAAG3H,SAAS,CAAC4H,IAAI,CAAC;IAClCjB,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAGY,EAAE,IAAKpB,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACY,SAAS,CAAC,UAAUV,GAAG,CAACF,OAAO,CAACK,QAAkB,CAAC,MAAMiB,EAAE;GAC3G,CAAC;EACF,MAAMI,OAAO,GACXJ,EAAuC,IAEvCE,YAAY,CAACF,EAAE,CAAC,CAACzD,IAAI,CACnBpE,MAAM,CAACqH,KAAK,EACZrH,MAAM,CAACsH,QAAQ,CAAC,GAAGf,OAAO,CAACgB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAEhF,MAAM;IAAEH,MAAM;IAAEoF,QAAQ;IAAEI,MAAM,EAAED;EAAO,CAAW;AAC/D,CAAC,CAAC;AAEJ;;;;;;AAAA7F,OAAA,CAAAiE,cAAA,GAAAA,cAAA;AAMO,MAAM8B,eAAe,GAAGA,CAI7B7B,KAAQ,EACRC,OAMC,KAUDvG,MAAM,CAACwG,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOC,oBAAS;EAC5B,MAAMC,QAAQ,GAAGL,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACK,QAAQ,CAAsB;EAEpE,MAAMwB,cAAc,GAAG,OAAOjI,WAAW,CAACkI,OAAO,CAAC,GAAG9B,OAAO,CAACgB,UAAU,SAAS,EAAE;IAChFR,OAAO,EAAET,KAAK,CAACzD,MAAM;IACrBmE,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGC,OAAO,IAAKT,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACY,SAAS,CAAC,IAAIV,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC,CAACE,SAAS,CAAC,GAAG,CAAC;GACrG,CAAC;EACF,MAAMkB,YAAY,GAAG,OAAO7I,GAAG,CAAC8I,UAAU,CAACH,cAAc,EAAE;IACzDI,MAAM,EAAEjC,OAAO,CAACiC,MAAM;IACtBC,YAAY,EAAElC,OAAO,CAACkC;GACvB,CAAC;EACF,MAAMC,aAAa,GAAGN,cAAc,CAACO,WAAW,CAACL,YAAY,CAAC;EAC9D,MAAMzF,MAAM,GACVA,MAA2B,IAE3B6F,aAAa,CAAC7F,MAAM,CAAC,CAACuB,IAAI,CACxBpE,MAAM,CAACqH,KAAK,EACZrH,MAAM,CAACsH,QAAQ,CAAC,GAAGf,OAAO,CAACgB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAE5E;IAAM;GACrB,CAAC,CACI;EAEV,MAAM+F,gBAAgB,GAAG,OAAOzI,WAAW,CAAC0I,OAAO,CAAC,GAAGtC,OAAO,CAACgB,UAAU,WAAW,EAAE;IACpFR,OAAO,EAAEJ,QAAQ;IACjBmC,eAAeA,CAACjB,EAAE;MAChB,OAAOA,EAAE;IACX,CAAC;IACDb,MAAM,EAAEV,KAAK;IACbyC,cAAcA,CAAC7B,OAAO;MACpB,OAAOA,OAAO,CAACX,OAAO,CAACK,QAAQ,CAAC;IAClC,CAAC;IACDK,OAAO,EAAG+B,GAAG,IAAKvC,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACY,SAAS,CAAC,UAAUV,GAAG,CAACwC,EAAE,CAAC1C,OAAO,CAACK,QAAkB,EAAEoC,GAAG,CAAC;GAC9G,CAAC;EACF,MAAME,cAAc,GAAG,OAAOzJ,GAAG,CAAC8I,UAAU,CAACK,gBAAgB,EAAE;IAC7DJ,MAAM,EAAEjC,OAAO,CAACiC,MAAM;IACtBC,YAAY,EAAElC,OAAO,CAACkC;GACvB,CAAC;EACF,MAAMU,eAAe,GAAGP,gBAAgB,CAACD,WAAW,CAACO,cAAc,CAAC;EACpE,MAAMpB,QAAQ,GAAID,EAAuC,IACvDsB,eAAe,CAACtB,EAAE,CAAC,CAACzD,IAAI,CACtBpE,MAAM,CAACqH,KAAK,EACZrH,MAAM,CAACsH,QAAQ,CAAC,GAAGf,OAAO,CAACgB,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,MAAMuB,cAAc,GAAG,OAAOjJ,WAAW,CAAC6H,IAAI,CAAC,GAAGzB,OAAO,CAACgB,UAAU,SAAS,EAAE;IAC7ER,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAG+B,GAAG,IAAKvC,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACY,SAAS,CAAC,UAAUV,GAAG,CAACwC,EAAE,CAAC1C,OAAO,CAACK,QAAkB,EAAEoC,GAAG,CAAC;GAC5G,CAAC;EACF,MAAMK,YAAY,GAAG,OAAO5J,GAAG,CAAC8I,UAAU,CAACa,cAAc,EAAE;IACzDZ,MAAM,EAAEjC,OAAO,CAACiC,MAAM;IACtBC,YAAY,EAAElC,OAAO,CAACkC;GACvB,CAAC;EACF,MAAMa,aAAa,GAAGF,cAAc,CAACT,WAAW,CAACU,YAAY,CAAC;EAC9D,MAAMpB,OAAO,GAAIJ,EAAuC,IACtDyB,aAAa,CAACzB,EAAE,CAAC,CAACzD,IAAI,CACpBpE,MAAM,CAACqH,KAAK,EACZrH,MAAM,CAACsH,QAAQ,CAAC,GAAGf,OAAO,CAACgB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAEhF,MAAM;IAAEiF,QAAQ;IAAEI,MAAM,EAAED;EAAO,CAAW;AACvD,CAAC,CAAC;AAAA7F,OAAA,CAAA+F,eAAA,GAAAA,eAAA","ignoreList":[]}
+{"version":3,"file":"Model.js","names":["RRX","_interopRequireWildcard","require","VariantSchema","ParseResult","Schema","DateTime","Effect","Option","_SqlClient","SqlResolver","SqlSchema","_getRequireWildcardCache","e","WeakMap","r","t","__esModule","default","has","get","n","__proto__","a","Object","defineProperty","getOwnPropertyDescriptor","u","hasOwnProperty","call","i","set","Class","Field","FieldExcept","FieldOnly","Struct","Union","extract","fieldEvolve","make","variants","defaultVariant","exports","fields","Override","Generated","schema","select","update","json","GeneratedByApp","insert","Sensitive","FieldOption","OptionFromNullOr","optionalWith","as","jsonCreate","nullable","jsonUpdate","DateTimeFromDate","transform","ValidDateFromSelf","DateTimeUtcFromSelf","decode","unsafeFromDate","encode","toDateUtc","Date","transformOrFail","String","s","_","ast","pipe","map","removeTime","match","onNone","fail","Type","onSome","dt","succeed","formatIsoDate","DateWithNow","Overrideable","generate","now","DateTimeWithNow","formatIso","DateTimeFromDateWithNow","DateFromSelf","DateTimeFromNumberWithNow","Number","toEpochMillis","DateTimeInsert","DateTimeUtc","DateTimeInsertFromDate","DateTimeInsertFromNumber","DateTimeUtcFromNumber","DateTimeUpdate","DateTimeUpdateFromDate","DateTimeUpdateFromNumber","JsonFromString","parsed","parseJson","makeRepository","Model","options","gen","sql","SqlClient","idSchema","idColumn","insertSchema","single","Request","Result","execute","request","onDialectOrElse","mysql","tableName","unprepared","results","orElse","returning","orDie","withSpan","spanPrefix","captureStackTrace","attributes","insertVoidSchema","void","insertVoid","updateSchema","raw","zipRight","withTransaction","updateVoidSchema","updateVoid","findByIdSchema","findOne","id","findById","deleteSchema","delete_","delete","makeDataLoaders","insertResolver","ordered","forEach","concurrency","insertLoader","dataLoader","window","maxBatchSize","insertExecute","makeExecute","insertVoidResolver","insertVoidLoader","insertVoidExecute","findByIdResolver","grouped","RequestGroupKey","ResultGroupKey","ids","in","findByIdLoader","findByIdExecute","deleteResolver","deleteLoader","deleteExecute"],"sources":["../../src/Model.ts"],"sourcesContent":[null],"mappings":";;;;;;AAGA,IAAAA,GAAA,GAAAC,uBAAA,CAAAC,OAAA;AACA,IAAAC,aAAA,GAAAF,uBAAA,CAAAC,OAAA;AACA,IAAAE,WAAA,GAAAH,uBAAA,CAAAC,OAAA;AACA,IAAAG,MAAA,GAAAJ,uBAAA,CAAAC,OAAA;AAEA,IAAAI,QAAA,GAAAL,uBAAA,CAAAC,OAAA;AAEA,IAAAK,MAAA,GAAAN,uBAAA,CAAAC,OAAA;AACA,IAAAM,MAAA,GAAAP,uBAAA,CAAAC,OAAA;AAEA,IAAAO,UAAA,GAAAP,OAAA;AACA,IAAAQ,WAAA,GAAAT,uBAAA,CAAAC,OAAA;AACA,IAAAS,SAAA,GAAAV,uBAAA,CAAAC,OAAA;AAA2C,SAAAU,yBAAAC,CAAA,6BAAAC,OAAA,mBAAAC,CAAA,OAAAD,OAAA,IAAAE,CAAA,OAAAF,OAAA,YAAAF,wBAAA,YAAAA,CAAAC,CAAA,WAAAA,CAAA,GAAAG,CAAA,GAAAD,CAAA,KAAAF,CAAA;AAAA,SAAAZ,wBAAAY,CAAA,EAAAE,CAAA,SAAAA,CAAA,IAAAF,CAAA,IAAAA,CAAA,CAAAI,UAAA,SAAAJ,CAAA,eAAAA,CAAA,uBAAAA,CAAA,yBAAAA,CAAA,WAAAK,OAAA,EAAAL,CAAA,QAAAG,CAAA,GAAAJ,wBAAA,CAAAG,CAAA,OAAAC,CAAA,IAAAA,CAAA,CAAAG,GAAA,CAAAN,CAAA,UAAAG,CAAA,CAAAI,GAAA,CAAAP,CAAA,OAAAQ,CAAA,KAAAC,SAAA,UAAAC,CAAA,GAAAC,MAAA,CAAAC,cAAA,IAAAD,MAAA,CAAAE,wBAAA,WAAAC,CAAA,IAAAd,CAAA,oBAAAc,CAAA,OAAAC,cAAA,CAAAC,IAAA,CAAAhB,CAAA,EAAAc,CAAA,SAAAG,CAAA,GAAAP,CAAA,GAAAC,MAAA,CAAAE,wBAAA,CAAAb,CAAA,EAAAc,CAAA,UAAAG,CAAA,KAAAA,CAAA,CAAAV,GAAA,IAAAU,CAAA,CAAAC,GAAA,IAAAP,MAAA,CAAAC,cAAA,CAAAJ,CAAA,EAAAM,CAAA,EAAAG,CAAA,IAAAT,CAAA,CAAAM,CAAA,IAAAd,CAAA,CAAAc,CAAA,YAAAN,CAAA,CAAAH,OAAA,GAAAL,CAAA,EAAAG,CAAA,IAAAA,CAAA,CAAAe,GAAA,CAAAlB,CAAA,EAAAQ,CAAA,GAAAA,CAAA;AAf3C;;;;AAiBA,MAAM;EACJW,KAAK;EACLC,KAAK;EACLC,WAAW;EACXC,SAAS;EACTC,MAAM;EACNC,KAAK;EACLC,OAAO;EACPC;AAAW,CACZ,gBAAGpC,aAAa,CAACqC,IAAI,CAAC;EACrBC,QAAQ,EAAE,CAAC,QAAQ,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,EAAE,YAAY,EAAE,YAAY,CAAC;EAC5EC,cAAc,EAAE;CACjB,CAAC;AAAAC,OAAA,CAAAJ,WAAA,GAAAA,WAAA;AAAAI,OAAA,CAAAL,OAAA,GAAAA,OAAA;AAAAK,OAAA,CAAAN,KAAA,GAAAA,KAAA;AAAAM,OAAA,CAAAP,MAAA,GAAAA,MAAA;AAAAO,OAAA,CAAAR,SAAA,GAAAA,SAAA;AAAAQ,OAAA,CAAAT,WAAA,GAAAA,WAAA;AAAAS,OAAA,CAAAV,KAAA,GAAAA,KAAA;AAAAU,OAAA,CAAAX,KAAA,GAAAA,KAAA;AAwHF;;;;AAIO,MAAMY,MAAM,GAAAD,OAAA,CAAAC,MAAA,GAA8EzC,aAAa,CAACyC,MAAM;AAErH;;;;AAIO,MAAMC,QAAQ,GAAAF,OAAA,CAAAE,QAAA,GAA2C1C,aAAa,CAAC0C,QAAQ;AActF;;;;;;;;AAQO,MAAMC,SAAS,GACpBC,MAAS,IAETd,KAAK,CAAC;EACJe,MAAM,EAAED,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAgBJ;;;;;;;;AAAAJ,OAAA,CAAAG,SAAA,GAAAA,SAAA;AAQO,MAAMK,cAAc,GACzBJ,MAAS,IAETd,KAAK,CAAC;EACJe,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAcJ;;;;;;;AAAAJ,OAAA,CAAAQ,cAAA,GAAAA,cAAA;AAOO,MAAME,SAAS,GACpBN,MAAS,IAETd,KAAK,CAAC;EACJe,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF;CACT,CAAC;AAsBJ;;;;;;;;;AAAAJ,OAAA,CAAAU,SAAA,GAAAA,SAAA;AASO,MAAMC,WAAW,GAAAX,OAAA,CAAAW,WAAA,gBAWdf,WAAW,CAAC;EAClBS,MAAM,EAAE3C,MAAM,CAACkD,gBAAgB;EAC/BH,MAAM,EAAE/C,MAAM,CAACkD,gBAAgB;EAC/BN,MAAM,EAAE5C,MAAM,CAACkD,gBAAgB;EAC/BL,IAAI,eAAE7C,MAAM,CAACmD,YAAY,CAAC;IAAEC,EAAE,EAAE;EAAQ,CAAE,CAAC;EAC3CC,UAAU,eAAErD,MAAM,CAACmD,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE,CAAC;EACjEC,UAAU,eAAEvD,MAAM,CAACmD,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE;CACjE,CAAQ;AAaX;;;;AAIO,MAAME,gBAAgB,GAAAlB,OAAA,CAAAkB,gBAAA,gBAAqBxD,MAAM,CAACyD,SAAS,CAChEzD,MAAM,CAAC0D,iBAAiB,EACxB1D,MAAM,CAAC2D,mBAAmB,EAC1B;EACEC,MAAM,EAAE3D,QAAQ,CAAC4D,cAAc;EAC/BC,MAAM,EAAE7D,QAAQ,CAAC8D;CAClB,CACF;AAQD;;;;;;;AAOO,MAAMC,IAAI,GAAA1B,OAAA,CAAA0B,IAAA,gBAAShE,MAAM,CAACiE,eAAe,CAC9CjE,MAAM,CAACkE,MAAM,EACblE,MAAM,CAAC2D,mBAAmB,EAC1B;EACEC,MAAM,EAAEA,CAACO,CAAC,EAAEC,CAAC,EAAEC,GAAG,KAChBpE,QAAQ,CAACkC,IAAI,CAACgC,CAAC,CAAC,CAACG,IAAI,CACnBnE,MAAM,CAACoE,GAAG,CAACtE,QAAQ,CAACuE,UAAU,CAAC,EAC/BrE,MAAM,CAACsE,KAAK,CAAC;IACXC,MAAM,EAAEA,CAAA,KAAM3E,WAAW,CAAC4E,IAAI,CAAC,IAAI5E,WAAW,CAAC6E,IAAI,CAACP,GAAG,EAAEF,CAAC,CAAC,CAAC;IAC5DU,MAAM,EAAGC,EAAE,IAAK/E,WAAW,CAACgF,OAAO,CAACD,EAAE;GACvC,CAAC,CACH;EACHhB,MAAM,EAAGgB,EAAE,IAAK/E,WAAW,CAACgF,OAAO,CAAC9E,QAAQ,CAAC+E,aAAa,CAACF,EAAE,CAAC;CAC/D,CACF;AAED;;;;AAIO,MAAMG,WAAW,GAAA3C,OAAA,CAAA2C,WAAA,gBAAGnF,aAAa,CAACoF,YAAY,CAAClB,IAAI,EAAEhE,MAAM,CAAC2D,mBAAmB,EAAE;EACtFwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAACuE,UAAU,CAAC;IAC3DK,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAACuE,UAAU,CAACM,EAAE,CAAC;GACvD;CACF,CAAC;AAEF;;;;AAIO,MAAMO,eAAe,GAAA/C,OAAA,CAAA+C,eAAA,gBAAGvF,aAAa,CAACoF,YAAY,CAAClF,MAAM,CAACkE,MAAM,EAAElE,MAAM,CAAC2D,mBAAmB,EAAE;EACnGwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAACqF,SAAS,CAAC;IAC1DT,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAACqF,SAAS,CAACR,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIO,MAAMS,uBAAuB,GAAAjD,OAAA,CAAAiD,uBAAA,gBAAGzF,aAAa,CAACoF,YAAY,CAAClF,MAAM,CAACwF,YAAY,EAAExF,MAAM,CAAC2D,mBAAmB,EAAE;EACjHwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAAC8D,SAAS,CAAC;IAC1Dc,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAAC8D,SAAS,CAACe,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIO,MAAMW,yBAAyB,GAAAnD,OAAA,CAAAmD,yBAAA,gBAAG3F,aAAa,CAACoF,YAAY,CAAClF,MAAM,CAAC0F,MAAM,EAAE1F,MAAM,CAAC2D,mBAAmB,EAAE;EAC7GwB,QAAQ,eAAEhF,MAAM,CAACsE,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMxE,MAAM,CAACqE,GAAG,CAACtE,QAAQ,CAACmF,GAAG,EAAEnF,QAAQ,CAAC0F,aAAa,CAAC;IAC9Dd,MAAM,EAAGC,EAAE,IAAK5E,MAAM,CAAC6E,OAAO,CAAC9E,QAAQ,CAAC0F,aAAa,CAACb,EAAE,CAAC;GAC1D;CACF,CAAC;AAcF;;;;;;;;;AASO,MAAMc,cAAc,GAAAtD,OAAA,CAAAsD,cAAA,gBAAmBhE,KAAK,CAAC;EAClDe,MAAM,EAAE3C,MAAM,CAAC6F,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBxC,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAcF;;;;;;;;;AASO,MAAMC,sBAAsB,GAAAxD,OAAA,CAAAwD,sBAAA,gBAA2BlE,KAAK,CAAC;EAClEe,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B1C,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAcF;;;;;;;;;AASO,MAAME,wBAAwB,GAAAzD,OAAA,CAAAyD,wBAAA,gBAA6BnE,KAAK,CAAC;EACtEe,MAAM,EAAE3C,MAAM,CAACgG,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC5C,IAAI,EAAE7C,MAAM,CAACgG;CACd,CAAC;AAeF;;;;;;;;;;AAUO,MAAMC,cAAc,GAAA3D,OAAA,CAAA2D,cAAA,gBAAmBrE,KAAK,CAAC;EAClDe,MAAM,EAAE3C,MAAM,CAAC6F,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBzC,MAAM,EAAEyC,eAAe;EACvBxC,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAeF;;;;;;;;;;AAUO,MAAMK,sBAAsB,GAAA5D,OAAA,CAAA4D,sBAAA,gBAA2BtE,KAAK,CAAC;EAClEe,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B3C,MAAM,EAAE2C,uBAAuB;EAC/B1C,IAAI,EAAE7C,MAAM,CAAC6F;CACd,CAAC;AAeF;;;;;;;;;;AAUO,MAAMM,wBAAwB,GAAA7D,OAAA,CAAA6D,wBAAA,gBAA6BvE,KAAK,CAAC;EACtEe,MAAM,EAAE3C,MAAM,CAACgG,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC7C,MAAM,EAAE6C,yBAAyB;EACjC5C,IAAI,EAAE7C,MAAM,CAACgG;CACd,CAAC;AAkBF;;;;;;;;AAQO,MAAMI,cAAc,GACzB1D,MAAS,IACY;EACrB,MAAM2D,MAAM,GAAGrG,MAAM,CAACsG,SAAS,CAAC5D,MAAa,CAAC;EAC9C,OAAOd,KAAK,CAAC;IACXe,MAAM,EAAE0D,MAAM;IACdtD,MAAM,EAAEsD,MAAM;IACdzD,MAAM,EAAEyD,MAAM;IACdxD,IAAI,EAAEH,MAAM;IACZW,UAAU,EAAEX,MAAM;IAClBa,UAAU,EAAEb;GACb,CAAQ;AACX,CAAC;AAED;;;;;;AAAAJ,OAAA,CAAA8D,cAAA,GAAAA,cAAA;AAMO,MAAMG,cAAc,GAAGA,CAG5BC,KAAQ,EAAEC,OAIX,KAwBCvG,MAAM,CAACwG,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOC,oBAAS;EAC5B,MAAMC,QAAQ,GAAGL,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACK,QAAQ,CAAsB;EACpE,MAAMA,QAAQ,GAAGL,OAAO,CAACK,QAAkB;EAE3C,MAAMC,YAAY,GAAGzG,SAAS,CAAC0G,MAAM,CAAC;IACpCC,OAAO,EAAET,KAAK,CAACzD,MAAM;IACrBmE,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGC,OAAO,IACfT,GAAG,CAACU,eAAe,CAAC;MAClBC,KAAK,EAAEA,CAAA,KACLX,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,IAAIZ,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC;gBAC3DT,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,UAAUZ,GAAG,CAACG,QAAQ,CAAC,sBAAsB,CAACU,UAAU,CAAClD,IAAI,CACrFpE,MAAM,CAACqE,GAAG,CAAC,CAAC,GAAGkD,OAAO,CAAC,KAAKA,OAAc,CAAC,CAC5C;MACHC,MAAM,EAAEA,CAAA,KAAMf,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,IAAIZ,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC,CAACO,SAAS,CAAC,GAAG,CAAC;KAC7F;GACJ,CAAC;EACF,MAAM5E,MAAM,GACVA,MAA2B,IAE3BgE,YAAY,CAAChE,MAAM,CAAC,CAACuB,IAAI,CACvBpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEjF;IAAM;GACrB,CAAC,CACI;EAEV,MAAMkF,gBAAgB,GAAG3H,SAAS,CAAC4H,IAAI,CAAC;IACtCjB,OAAO,EAAET,KAAK,CAACzD,MAAM;IACrBoE,OAAO,EAAGC,OAAO,IAAKT,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,IAAIZ,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC;GACtF,CAAC;EACF,MAAMe,UAAU,GACdpF,MAA2B,IAE3BkF,gBAAgB,CAAClF,MAAM,CAAC,CAACuB,IAAI,CAC3BpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,aAAa,EAAE;IAClDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEjF;IAAM;GACrB,CAAC,CACI;EAEV,MAAMqF,YAAY,GAAG9H,SAAS,CAAC0G,MAAM,CAAC;IACpCC,OAAO,EAAET,KAAK,CAAC5D,MAAM;IACrBsE,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGC,OAAO,IACfT,GAAG,CAACU,eAAe,CAAC;MAClBC,KAAK,EAAEA,CAAA,KACLX,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,QAAQZ,GAAG,CAAC/D,MAAM,CAACwE,OAAO,EAAE,CAACN,QAAQ,CAAC,CAAC,UAAUH,GAAG,CAACG,QAAQ,CAAC,MAC/FM,OAAO,CAACN,QAAQ,CAClB,EAAE,CAACuB,GAAG,CAAC/D,IAAI,CACTpE,MAAM,CAACoI,QAAQ,CACb3B,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,UAAUZ,GAAG,CAACF,OAAO,CAACK,QAAkB,CAAC,MACjFM,OAAO,CAACN,QAAQ,CAClB,EAAE,CACH,EACDH,GAAG,CAAC4B,eAAe,CACpB;MACHb,MAAM,EAAEA,CAAA,KACNf,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,QAAQZ,GAAG,CAAC/D,MAAM,CAACwE,OAAO,EAAE,CAACN,QAAQ,CAAC,CAAC,UAAUH,GAAG,CAACG,QAAQ,CAAC,MAC/FM,OAAO,CAACN,QAAQ,CAClB;KACH;GACJ,CAAC;EACF,MAAMlE,MAAM,GACVA,MAA2B,IAE3BwF,YAAY,CAACxF,MAAM,CAAC,CAAC0B,IAAI,CACvBpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEpF;IAAM;GACrB,CAAC,CACI;EAEV,MAAM4F,gBAAgB,GAAGlI,SAAS,CAAC4H,IAAI,CAAC;IACtCjB,OAAO,EAAET,KAAK,CAAC5D,MAAM;IACrBuE,OAAO,EAAGC,OAAO,IACfT,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,QAAQZ,GAAG,CAAC/D,MAAM,CAACwE,OAAO,EAAE,CAACN,QAAQ,CAAC,CAAC,UAAUH,GAAG,CAACG,QAAQ,CAAC,MAC/FM,OAAO,CAACN,QAAQ,CAClB;GACH,CAAC;EACF,MAAM2B,UAAU,GACd7F,MAA2B,IAE3B4F,gBAAgB,CAAC5F,MAAM,CAAC,CAAC0B,IAAI,CAC3BpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,aAAa,EAAE;IAClDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEpF;IAAM;GACrB,CAAC,CACI;EAEV,MAAM8F,cAAc,GAAGpI,SAAS,CAACqI,OAAO,CAAC;IACvC1B,OAAO,EAAEJ,QAAQ;IACjBK,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGyB,EAAE,IAAKjC,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,UAAUZ,GAAG,CAACG,QAAQ,CAAC,MAAM8B,EAAE;GAC3F,CAAC;EACF,MAAMC,QAAQ,GACZD,EAAuC,IAEvCF,cAAc,CAACE,EAAE,CAAC,CAACtE,IAAI,CACrBpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,MAAME,YAAY,GAAGxI,SAAS,CAAC4H,IAAI,CAAC;IAClCjB,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAGyB,EAAE,IAAKjC,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,UAAUZ,GAAG,CAACG,QAAQ,CAAC,MAAM8B,EAAE;GACzF,CAAC;EACF,MAAMG,OAAO,GACXH,EAAuC,IAEvCE,YAAY,CAACF,EAAE,CAAC,CAACtE,IAAI,CACnBpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAE7F,MAAM;IAAEoF,UAAU;IAAEvF,MAAM;IAAE6F,UAAU;IAAEI,QAAQ;IAAEG,MAAM,EAAED;EAAO,CAAW;AACvF,CAAC,CAAC;AAEJ;;;;;;AAAAzG,OAAA,CAAAiE,cAAA,GAAAA,cAAA;AAMO,MAAM0C,eAAe,GAAGA,CAI7BzC,KAAQ,EACRC,OAMC,KAWDvG,MAAM,CAACwG,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOC,oBAAS;EAC5B,MAAMC,QAAQ,GAAGL,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACK,QAAQ,CAAsB;EACpE,MAAMA,QAAQ,GAAGL,OAAO,CAACK,QAAkB;EAE3C,MAAMoC,cAAc,GAAG,OAAO7I,WAAW,CAAC8I,OAAO,CAAC,GAAG1C,OAAO,CAACqB,UAAU,SAAS,EAAE;IAChFb,OAAO,EAAET,KAAK,CAACzD,MAAM;IACrBmE,MAAM,EAAEV,KAAK;IACbW,OAAO,EAAGC,OAAO,IACfT,GAAG,CAACU,eAAe,CAAC;MAClBC,KAAK,EAAEA,CAAA,KACLpH,MAAM,CAACkJ,OAAO,CAAChC,OAAO,EAAGA,OAAO,IAC9BT,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,IAAIZ,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC;gBAC7DT,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,UAAUZ,GAAG,CAACG,QAAQ,CAAC,sBAAsB,CAACU,UAAU,CAAClD,IAAI,CACnFpE,MAAM,CAACqE,GAAG,CAAC,CAAC,GAAGkD,OAAO,CAAC,KAAKA,OAAO,CAAC,CAAC,CAAQ,CAAC,CAC/C,EAAE;QAAE4B,WAAW,EAAE;MAAE,CAAE,CAAC;MAC3B3B,MAAM,EAAEA,CAAA,KAAMf,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,IAAIZ,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC,CAACO,SAAS,CAAC,GAAG,CAAC;KAC7F;GACJ,CAAC;EACF,MAAM2B,YAAY,GAAG,OAAO3J,GAAG,CAAC4J,UAAU,CAACL,cAAc,EAAE;IACzDM,MAAM,EAAE/C,OAAO,CAAC+C,MAAM;IACtBC,YAAY,EAAEhD,OAAO,CAACgD;GACvB,CAAC;EACF,MAAMC,aAAa,GAAGR,cAAc,CAACS,WAAW,CAACL,YAAY,CAAC;EAC9D,MAAMvG,MAAM,GACVA,MAA2B,IAE3B2G,aAAa,CAAC3G,MAAM,CAAC,CAACuB,IAAI,CACxBpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEjF;IAAM;GACrB,CAAC,CACI;EAEV,MAAM6G,kBAAkB,GAAG,OAAOvJ,WAAW,CAAC6H,IAAI,CAAC,GAAGzB,OAAO,CAACqB,UAAU,aAAa,EAAE;IACrFb,OAAO,EAAET,KAAK,CAACzD,MAAM;IACrBoE,OAAO,EAAGC,OAAO,IAAKT,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,IAAIZ,GAAG,CAAC5D,MAAM,CAACqE,OAAO,CAAC;GACtF,CAAC;EACF,MAAMyC,gBAAgB,GAAG,OAAOlK,GAAG,CAAC4J,UAAU,CAACK,kBAAkB,EAAE;IACjEJ,MAAM,EAAE/C,OAAO,CAAC+C,MAAM;IACtBC,YAAY,EAAEhD,OAAO,CAACgD;GACvB,CAAC;EACF,MAAMK,iBAAiB,GAAGF,kBAAkB,CAACD,WAAW,CAACE,gBAAgB,CAAC;EAC1E,MAAM1B,UAAU,GACdpF,MAA2B,IAE3B+G,iBAAiB,CAAC/G,MAAM,CAAC,CAACuB,IAAI,CAC5BpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,aAAa,EAAE;IAClDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEjF;IAAM;GACrB,CAAC,CACI;EAEV,MAAMgH,gBAAgB,GAAG,OAAO1J,WAAW,CAAC2J,OAAO,CAAC,GAAGvD,OAAO,CAACqB,UAAU,WAAW,EAAE;IACpFb,OAAO,EAAEJ,QAAQ;IACjBoD,eAAeA,CAACrB,EAAE;MAChB,OAAOA,EAAE;IACX,CAAC;IACD1B,MAAM,EAAEV,KAAK;IACb0D,cAAcA,CAAC9C,OAAO;MACpB,OAAOA,OAAO,CAACN,QAAQ,CAAC;IAC1B,CAAC;IACDK,OAAO,EAAGgD,GAAG,IAAKxD,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,UAAUZ,GAAG,CAACyD,EAAE,CAACtD,QAAQ,EAAEqD,GAAG,CAAC;GAC5F,CAAC;EACF,MAAME,cAAc,GAAG,OAAO1K,GAAG,CAAC4J,UAAU,CAACQ,gBAAgB,EAAE;IAC7DP,MAAM,EAAE/C,OAAO,CAAC+C,MAAM;IACtBC,YAAY,EAAEhD,OAAO,CAACgD;GACvB,CAAC;EACF,MAAMa,eAAe,GAAGP,gBAAgB,CAACJ,WAAW,CAACU,cAAc,CAAC;EACpE,MAAMxB,QAAQ,GAAID,EAAuC,IACvD0B,eAAe,CAAC1B,EAAE,CAAC,CAACtE,IAAI,CACtBpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,MAAM2B,cAAc,GAAG,OAAOlK,WAAW,CAAC6H,IAAI,CAAC,GAAGzB,OAAO,CAACqB,UAAU,SAAS,EAAE;IAC7Eb,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAGgD,GAAG,IAAKxD,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACc,SAAS,CAAC,UAAUZ,GAAG,CAACyD,EAAE,CAACtD,QAAQ,EAAEqD,GAAG,CAAC;GAC1F,CAAC;EACF,MAAMK,YAAY,GAAG,OAAO7K,GAAG,CAAC4J,UAAU,CAACgB,cAAc,EAAE;IACzDf,MAAM,EAAE/C,OAAO,CAAC+C,MAAM;IACtBC,YAAY,EAAEhD,OAAO,CAACgD;GACvB,CAAC;EACF,MAAMgB,aAAa,GAAGF,cAAc,CAACZ,WAAW,CAACa,YAAY,CAAC;EAC9D,MAAMzB,OAAO,GAAIH,EAAuC,IACtD6B,aAAa,CAAC7B,EAAE,CAAC,CAACtE,IAAI,CACpBpE,MAAM,CAAC0H,KAAK,EACZ1H,MAAM,CAAC2H,QAAQ,CAAC,GAAGpB,OAAO,CAACqB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAE7F,MAAM;IAAEoF,UAAU;IAAEU,QAAQ;IAAEG,MAAM,EAAED;EAAO,CAAW;AACnE,CAAC,CAAC;AAAAzG,OAAA,CAAA2G,eAAA,GAAAA,eAAA","ignoreList":[]}

dist/dts/Migrator/FileSystem.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"FileSystem.d.ts","sourceRoot":"","sources":["../../../src/Migrator/FileSystem.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,EAAE,UAAU,EAAE,MAAM,6BAA6B,CAAA;AAGxD,OAAO,KAAK,EAAE,MAAM,EAAqB,MAAM,gBAAgB,CAAA;AAG/D;;;GAGG;AACH,eAAO,MAAM,cAAc,cAAe,MAAM,KAAG,MAAM,CAAC,UAAU,CA4BjE,CAAA"}
+{"version":3,"file":"FileSystem.d.ts","sourceRoot":"","sources":["../../../src/Migrator/FileSystem.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,EAAE,UAAU,EAAE,MAAM,6BAA6B,CAAA;AAGxD,OAAO,KAAK,EAAE,MAAM,EAAqB,MAAM,gBAAgB,CAAA;AAG/D;;;GAGG;AACH,eAAO,MAAM,cAAc,cAAe,MAAM,KAAG,MAAM,CAAC,UAAU,CA6BjE,CAAA"}

dist/dts/Model.d.ts

@@ -477,3 +477,5 @@ import * as VariantSchema from "@effect/experimental/VariantSchema";
     readonly insert: (insert: S["insert"]["Type"]) => Effect.Effect<S["Type"], never, S["Context"] | S["insert"]["Context"]>;
+    readonly insertVoid: (insert: S["insert"]["Type"]) => Effect.Effect<void, never, S["Context"] | S["insert"]["Context"]>;
     readonly update: (update: S["update"]["Type"]) => Effect.Effect<S["Type"], never, S["Context"] | S["update"]["Context"]>;
+    readonly updateVoid: (update: S["update"]["Type"]) => Effect.Effect<void, never, S["Context"] | S["update"]["Context"]>;
     readonly findById: (id: Schema.Schema.Type<S["fields"][Id]>) => Effect.Effect<Option.Option<S["Type"]>, never, S["Context"] | Schema.Schema.Context<S["fields"][Id]>>;
@@ -496,2 +498,3 @@ readonly delete: (id: Schema.Schema.Type<S["fields"][Id]>) => Effect.Effect<void, never, Schema.Schema.Context<S["fields"][Id]>>;
     readonly insert: (insert: S["insert"]["Type"]) => Effect.Effect<S["Type"]>;
+    readonly insertVoid: (insert: S["insert"]["Type"]) => Effect.Effect<void>;
     readonly findById: (id: Schema.Schema.Type<S["fields"][Id]>) => Effect.Effect<Option.Option<S["Type"]>>;
@@ -498,0 +501,0 @@ readonly delete: (id: Schema.Schema.Type<S["fields"][Id]>) => Effect.Effect<void>;

dist/dts/Model.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"Model.d.ts","sourceRoot":"","sources":["../../src/Model.ts"],"names":[],"mappings":"AAIA,OAAO,KAAK,aAAa,MAAM,oCAAoC,CAAA;AAEnE,OAAO,KAAK,MAAM,MAAM,uBAAuB,CAAA;AAC/C,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,cAAc,CAAA;AACzC,OAAO,KAAK,QAAQ,MAAM,iBAAiB,CAAA;AAC3C,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AACpD,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,cAAc,CAAA;AACzC,OAAO,EAAE,SAAS,EAAE,MAAM,gBAAgB,CAAA;AAI1C,QAAA,MACE,KAAK;;;;;;;GACL,KAAK,0RACL,WAAW,qcACX,SAAS,kQACT,MAAM,iMACN,KAAK,wOACL,OAAO;;;GACP,WAAW;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;CAIX,CAAA;AAEF;;;GAGG;AACH,MAAM,MAAM,GAAG,GAAG,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG;IACpC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAA;IACrC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAClC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAClC,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAChC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IACtC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;CACvC,CAAA;AAED;;;GAGG;AACH,MAAM,MAAM,YAAY,GAAG,MAAM,CAAC,MAAM,CAAC,YAAY,GAAG;IACtD,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAA;IACrC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IAC3C,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IAC3C,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IACzC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IAC/C,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;CAChD,CAAA;AAED;;;GAGG;AACH,MAAM,MAAM,gBAAgB,GAAG,QAAQ,GAAG,QAAQ,GAAG,QAAQ,CAAA;AAE7D;;;GAGG;AACH,MAAM,MAAM,YAAY,GAAG,MAAM,GAAG,YAAY,GAAG,YAAY,CAAA;AAE/D,OAAO;AACL;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAwCG;AACH,KAAK;AACL;;;GAGG;AACH,OAAO;AACP;;;GAGG;AACH,KAAK;AACL;;;GAGG;AACH,WAAW;AACX;;;GAGG;AACH,WAAW;AACX;;;GAGG;AACH,SAAS;AACT;;;GAGG;AACH,MAAM;AACN;;;GAGG;AACH,KAAK,EACN,CAAA;AAED;;;GAGG;AACH,eAAO,MAAM,MAAM,EAAE,CAAC,CAAC,SAAS,aAAa,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE,IAAI,EAAE,CAAC,KAAK,CAAC,CAAC,aAAa,CAAC,MAAM,CAAwB,CAAA;AAErH;;;GAGG;AACH,eAAO,MAAM,QAAQ,EAAE,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,KAAK,CAAC,UAAU,CAA0B,CAAA;AAEtF;;;GAGG;AACH,MAAM,WAAW,SAAS,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CAAE,SACrF,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAA;CACjB,CAAC;CACF;AAEF;;;;;;;GAOG;AACH,eAAO,MAAM,SAAS,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC1E,CAAC,KACR,SAAS,CAAC,CAAC,CAKV,CAAA;AAEJ;;;GAGG;AACH,MAAM,WAAW,cAAc,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CACxF,SACE,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAA;CACjB,CAAC;CACJ;AAEF;;;;;;;GAOG;AACH,eAAO,MAAM,cAAc,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC/E,CAAC,KACR,cAAc,CAAC,CAAC,CAMf,CAAA;AAEJ;;;GAGG;AACH,MAAM,WAAW,SAAS,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CAAE,SACrF,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;CACnB,CAAC;CACF;AAEF;;;;;;GAMG;AACH,eAAO,MAAM,SAAS,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC1E,CAAC,KACR,SAAS,CAAC,CAAC,CAKV,CAAA;AAEJ;;;;;;;;GAQG;AACH,MAAM,WAAW,WAAW,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,CAAE,SACxD,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAA;IAC3C,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAA;IAC3C,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAA;IAC3C,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAA;KAAE,CAAC,CAAA;IACvD,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAC;QAAC,QAAQ,EAAE,IAAI,CAAA;KAAE,CAAC,CAAA;IAC7E,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAC;QAAC,QAAQ,EAAE,IAAI,CAAA;KAAE,CAAC,CAAA;CAC9E,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,WAAW,EAAE,CAAC,KAAK,SAAS,aAAa,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,MAAM,CAAC,MAAM,CAAC,GAAG,EACnF,IAAI,EAAE,KAAK,KACR,KAAK,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,WAAW,CAAC,KAAK,CAAC,GACrD,KAAK,SAAS,aAAa,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC,GAAG,aAAa,CAAC,KAAK,CAC9D;IACE,QAAQ,EAAE,CAAC,IAAI,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GACnD,CAAC,SAAS,gBAAgB,GAAG,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,GAC5D,MAAM,CAAC,YAAY,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAC;QAAC,QAAQ,EAAE,IAAI,CAAA;KAAE,CAAC,GACzD,KAAK;CACV,CACF,GACH,KAOS,CAAA;AAEX;;;GAGG;AACH,MAAM,WAAW,gBAAiB,SAChC,MAAM,CAAC,SAAS,CACd,OAAO,MAAM,CAAC,iBAAiB,EAC/B,OAAO,MAAM,CAAC,mBAAmB,CAClC;CACD;AAEF;;;GAGG;AACH,eAAO,MAAM,gBAAgB,EAAE,gBAO9B,CAAA;AAED;;;GAGG;AACH,MAAM,WAAW,IAAK,SAAQ,MAAM,CAAC,eAAe,CAAC,OAAO,MAAM,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,mBAAmB,CAAC;CAAG;AAEhH;;;;;;GAMG;AACH,eAAO,MAAM,IAAI,EAAE,IAclB,CAAA;AAED;;;GAGG;AACH,eAAO,MAAM,WAAW,yDAKtB,CAAA;AAEF;;;GAGG;AACH,eAAO,MAAM,eAAe,yDAK1B,CAAA;AAEF;;;GAGG;AACH,eAAO,MAAM,uBAAuB,kEAKlC,CAAA;AAEF;;;GAGG;AACH,eAAO,MAAM,yBAAyB,yDAKpC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,cAAe,SAC9B,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;IAC1C,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,cAAc,EAAE,cAI3B,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,sBAAuB,SACtC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,gBAAgB,CAAA;IACjC,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,UAAU,CAAC,IAAI,CAAC,CAAA;IAC1E,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,sBAAsB,EAAE,sBAInC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,wBAAyB,SACxC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;IACpD,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;CACnD,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,wBAAwB,EAAE,wBAIrC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,cAAe,SAC9B,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;IAC1C,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;;GASG;AACH,eAAO,MAAM,cAAc,EAAE,cAK3B,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,sBAAuB,SACtC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,gBAAgB,CAAA;IACjC,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,UAAU,CAAC,IAAI,CAAC,CAAA;IAC1E,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,UAAU,CAAC,IAAI,CAAC,CAAA;IAC1E,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;;GASG;AACH,eAAO,MAAM,sBAAsB,EAAE,sBAKnC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,wBAAyB,SACxC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;IACpD,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;CACnD,CAAC;CACF;AAEF;;;;;;;;;GASG;AACH,eAAO,MAAM,wBAAwB,EAAE,wBAKrC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,cAAc,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CACxF,SACE,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;IACvF,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;IACvF,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;IACvF,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAA;IAChB,QAAQ,CAAC,UAAU,EAAE,CAAC,CAAA;IACtB,QAAQ,CAAC,UAAU,EAAE,CAAC,CAAA;CACvB,CAAC;CACJ;AAEF;;;;;;;GAOG;AACH,eAAO,MAAM,cAAc,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC/E,CAAC,KACR,cAAc,CAAC,CAAC,CAUlB,CAAA;AAED;;;;;GAKG;AACH,eAAO,MAAM,cAAc,GACzB,CAAC,SAAS,GAAG,EACb,EAAE,SAAS,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,SACzE,CAAC,WAAW;IACnB,QAAQ,CAAC,SAAS,EAAE,MAAM,CAAA;IAC1B,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAA;IAC3B,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAA;CACtB,KAAG,MAAM,CAAC,MAAM,CACf;IACE,QAAQ,CAAC,MAAM,EAAE,CACf,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KACxB,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,CAAC,CAAA;IAC3E,QAAQ,CAAC,MAAM,EAAE,CACf,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KACxB,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,CAAC,CAAA;IAC3E,QAAQ,CAAC,QAAQ,EAAE,CACjB,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KACpC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,CAAA;IAC1G,QAAQ,CAAC,MAAM,EAAE,CACf,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KACpC,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,CAAA;CACxE,EACD,KAAK,EACL,SAAS,CAyEP,CAAA;AAEJ;;;;;GAKG;AACH,eAAO,MAAM,eAAe,GAC1B,CAAC,SAAS,YAAY,EACtB,EAAE,SAAS,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,SAEzE,CAAC,WACC;IACP,QAAQ,CAAC,SAAS,EAAE,MAAM,CAAA;IAC1B,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAA;IAC3B,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAA;IACrB,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAA;IAC9B,QAAQ,CAAC,YAAY,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;CAC3C,KACA,MAAM,CAAC,MAAM,CACd;IACE,QAAQ,CAAC,MAAM,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KAAK,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAA;IAC1E,QAAQ,CAAC,QAAQ,EAAE,CAAC,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAA;IACvG,QAAQ,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;CAClF,EACD,KAAK,EACL,SAAS,GAAG,KAAK,CAuEf,CAAA"}
+{"version":3,"file":"Model.d.ts","sourceRoot":"","sources":["../../src/Model.ts"],"names":[],"mappings":"AAIA,OAAO,KAAK,aAAa,MAAM,oCAAoC,CAAA;AAEnE,OAAO,KAAK,MAAM,MAAM,uBAAuB,CAAA;AAC/C,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,cAAc,CAAA;AACzC,OAAO,KAAK,QAAQ,MAAM,iBAAiB,CAAA;AAC3C,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AACpD,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,cAAc,CAAA;AACzC,OAAO,EAAE,SAAS,EAAE,MAAM,gBAAgB,CAAA;AAI1C,QAAA,MACE,KAAK;;;;;;;GACL,KAAK,0RACL,WAAW,uIAsQa,OAAQ,MAAM,CAAC,GAAG,GAAG,OAAO,iBACrD,CAAK,GAAD,8QAtQH,SAAS,uIA+PA,OACR,MAAM,CAAC,GAAG,GAAE,OACd,iBACa,CAAC,GAAG,2EAjQhB,MAAM,iMACN,KAAK,wOACL,OAAO;;;GACP,WAAW;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;CAIX,CAAA;AAEF;;;GAGG;AACH,MAAM,MAAM,GAAG,GAAG,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG;IACpC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAA;IACrC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAClC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAClC,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAChC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IACtC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;CACvC,CAAA;AAED;;;GAGG;AACH,MAAM,MAAM,YAAY,GAAG,MAAM,CAAC,MAAM,CAAC,YAAY,GAAG;IACtD,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAA;IACrC,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IAC3C,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IAC3C,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IACzC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;IAC/C,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,MAAM,CAAC,YAAY,CAAA;CAChD,CAAA;AAED;;;GAGG;AACH,MAAM,MAAM,gBAAgB,GAAG,QAAQ,GAAG,QAAQ,GAAG,QAAQ,CAAA;AAE7D;;;GAGG;AACH,MAAM,MAAM,YAAY,GAAG,MAAM,GAAG,YAAY,GAAG,YAAY,CAAA;AAE/D,OAAO;AACL;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAwCG;AACH,KAAK;AACL;;;GAGG;AACH,OAAO;AACP;;;GAGG;AACH,KAAK;AACL;;;GAGG;AACH,WAAW;AACX;;;GAGG;AACH,WAAW;AACX;;;GAGG;AACH,SAAS;AACT;;;GAGG;AACH,MAAM;AACN;;;GAGG;AACH,KAAK,EACN,CAAA;AAED;;;GAGG;AACH,eAAO,MAAM,MAAM,EAAE,CAAC,CAAC,SAAS,aAAa,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE,IAAI,EAAE,CAAC,KAAK,CAAC,CAAC,aAAa,CAAC,MAAM,CAAwB,CAAA;AAErH;;;GAGG;AACH,eAAO,MAAM,QAAQ,EAAE,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,KAAK,CAAC,GAAG,KAAK,CAAC,UAAU,CAA0B,CAAA;AAEtF;;;GAGG;AACH,MAAM,WAAW,SAAS,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CAAE,SACrF,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAA;CACjB,CAAC;CACF;AAEF;;;;;;;GAOG;AACH,eAAO,MAAM,SAAS,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC1E,CAAC,KACR,SAAS,CAAC,CAAC,CAKV,CAAA;AAEJ;;;GAGG;AACH,MAAM,WAAW,cAAc,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CACxF,SACE,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAA;CACjB,CAAC;CACJ;AAEF;;;;;;;GAOG;AACH,eAAO,MAAM,cAAc,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC/E,CAAC,KACR,cAAc,CAAC,CAAC,CAMf,CAAA;AAEJ;;;GAGG;AACH,MAAM,WAAW,SAAS,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CAAE,SACrF,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;IAClB,QAAQ,CAAC,MAAM,EAAE,CAAC,CAAA;CACnB,CAAC;CACF;AAEF;;;;;;GAMG;AACH,eAAO,MAAM,SAAS,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC1E,CAAC,KACR,SAAS,CAAC,CAAC,CAKV,CAAA;AAEJ;;;;;;;;GAQG;AACH,MAAM,WAAW,WAAW,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,CAAE,SACxD,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAA;IAC3C,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAA;IAC3C,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAA;IAC3C,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAA;KAAE,CAAC,CAAA;IACvD,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAC;QAAC,QAAQ,EAAE,IAAI,CAAA;KAAE,CAAC,CAAA;IAC7E,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAC;QAAC,QAAQ,EAAE,IAAI,CAAA;KAAE,CAAC,CAAA;CAC9E,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,WAAW,EAAE,CAAC,KAAK,SAAS,aAAa,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,MAAM,CAAC,MAAM,CAAC,GAAG,EACnF,IAAI,EAAE,KAAK,KACR,KAAK,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,WAAW,CAAC,KAAK,CAAC,GACrD,KAAK,SAAS,aAAa,CAAC,KAAK,CAAC,MAAM,CAAC,CAAC,GAAG,aAAa,CAAC,KAAK,CAC9D;IACE,QAAQ,EAAE,CAAC,IAAI,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GACnD,CAAC,SAAS,gBAAgB,GAAG,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,GAC5D,MAAM,CAAC,YAAY,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE;QAAE,EAAE,EAAE,QAAQ,CAAC;QAAC,QAAQ,EAAE,IAAI,CAAA;KAAE,CAAC,GACzD,KAAK;CACV,CACF,GACH,KAOS,CAAA;AAEX;;;GAGG;AACH,MAAM,WAAW,gBAAiB,SAChC,MAAM,CAAC,SAAS,CACd,OAAO,MAAM,CAAC,iBAAiB,EAC/B,OAAO,MAAM,CAAC,mBAAmB,CAClC;CACD;AAEF;;;GAGG;AACH,eAAO,MAAM,gBAAgB,EAAE,gBAO9B,CAAA;AAED;;;GAGG;AACH,MAAM,WAAW,IAAK,SAAQ,MAAM,CAAC,eAAe,CAAC,OAAO,MAAM,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,mBAAmB,CAAC;CAAG;AAEhH;;;;;;GAMG;AACH,eAAO,MAAM,IAAI,EAAE,IAclB,CAAA;AAED;;;GAGG;AACH,eAAO,MAAM,WAAW,yDAKtB,CAAA;AAEF;;;GAGG;AACH,eAAO,MAAM,eAAe,yDAK1B,CAAA;AAEF;;;GAGG;AACH,eAAO,MAAM,uBAAuB,kEAKlC,CAAA;AAEF;;;GAGG;AACH,eAAO,MAAM,yBAAyB,yDAKpC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,cAAe,SAC9B,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;IAC1C,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,cAAc,EAAE,cAI3B,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,sBAAuB,SACtC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,gBAAgB,CAAA;IACjC,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,UAAU,CAAC,IAAI,CAAC,CAAA;IAC1E,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,sBAAsB,EAAE,sBAInC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,wBAAyB,SACxC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;IACpD,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;CACnD,CAAC;CACF;AAEF;;;;;;;;GAQG;AACH,eAAO,MAAM,wBAAwB,EAAE,wBAIrC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,cAAe,SAC9B,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;IAC1C,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;;GASG;AACH,eAAO,MAAM,cAAc,EAAE,cAK3B,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,sBAAuB,SACtC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,gBAAgB,CAAA;IACjC,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,UAAU,CAAC,IAAI,CAAC,CAAA;IAC1E,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,UAAU,CAAC,IAAI,CAAC,CAAA;IAC1E,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,WAAW,CAAA;CACzC,CAAC;CACF;AAEF;;;;;;;;;GASG;AACH,eAAO,MAAM,sBAAsB,EAAE,sBAKnC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,wBAAyB,SACxC,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;IACpD,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAC,YAAY,CAAC,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC,CAAA;IACjE,QAAQ,CAAC,IAAI,EAAE,OAAO,MAAM,CAAC,qBAAqB,CAAA;CACnD,CAAC;CACF;AAEF;;;;;;;;;GASG;AACH,eAAO,MAAM,wBAAwB,EAAE,wBAKrC,CAAA;AAEF;;;GAGG;AACH,MAAM,WAAW,cAAc,CAAC,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,CACxF,SACE,aAAa,CAAC,KAAK,CAAC;IAClB,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;IACvF,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;IACvF,QAAQ,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;IACvF,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAA;IAChB,QAAQ,CAAC,UAAU,EAAE,CAAC,CAAA;IACtB,QAAQ,CAAC,UAAU,EAAE,CAAC,CAAA;CACvB,CAAC;CACJ;AAEF;;;;;;;GAOG;AACH,eAAO,MAAM,cAAc,GAAI,CAAC,SAAS,MAAM,CAAC,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC,iBAAiB,CAAC,GAAG,UAC/E,CAAC,KACR,cAAc,CAAC,CAAC,CAUlB,CAAA;AAED;;;;;GAKG;AACH,eAAO,MAAM,cAAc,GACzB,CAAC,SAAS,GAAG,EACb,EAAE,SAAS,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,SACzE,CAAC,WAAW;IACnB,QAAQ,CAAC,SAAS,EAAE,MAAM,CAAA;IAC1B,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAA;IAC3B,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAA;CACtB,KAAG,MAAM,CAAC,MAAM,CACf;IACE,QAAQ,CAAC,MAAM,EAAE,CACf,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KACxB,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,CAAC,CAAA;IAC3E,QAAQ,CAAC,UAAU,EAAE,CACnB,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KACxB,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,CAAC,CAAA;IACtE,QAAQ,CAAC,MAAM,EAAE,CACf,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KACxB,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,CAAC,CAAA;IAC3E,QAAQ,CAAC,UAAU,EAAE,CACnB,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KACxB,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,CAAC,CAAA;IACtE,QAAQ,CAAC,QAAQ,EAAE,CACjB,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KACpC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,SAAS,CAAC,GAAG,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,CAAA;IAC1G,QAAQ,CAAC,MAAM,EAAE,CACf,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KACpC,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,EAAE,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,CAAA;CACxE,EACD,KAAK,EACL,SAAS,CAiIP,CAAA;AAEJ;;;;;GAKG;AACH,eAAO,MAAM,eAAe,GAC1B,CAAC,SAAS,YAAY,EACtB,EAAE,SAAS,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC,SAEzE,CAAC,WACC;IACP,QAAQ,CAAC,SAAS,EAAE,MAAM,CAAA;IAC1B,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAA;IAC3B,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAA;IACrB,QAAQ,CAAC,MAAM,EAAE,aAAa,CAAA;IAC9B,QAAQ,CAAC,YAAY,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;CAC3C,KACA,MAAM,CAAC,MAAM,CACd;IACE,QAAQ,CAAC,MAAM,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KAAK,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAA;IAC1E,QAAQ,CAAC,UAAU,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,MAAM,CAAC,KAAK,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;IACzE,QAAQ,CAAC,QAAQ,EAAE,CAAC,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAA;IACvG,QAAQ,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;CAClF,EACD,KAAK,EACL,SAAS,GAAG,KAAK,CAqGf,CAAA"}

dist/esm/Migrator/FileSystem.js

@@ -18,4 +18,5 @@ /**
   onSome: ([basename, id, name]) => [[Number(id), name, Effect.promise(() => import( /* @vite-ignore */
+  /* webpackIgnore: true */
   `${directory}/${basename}`))]]
 })).sort(([a], [b]) => a - b)));
 //# sourceMappingURL=FileSystem.js.map

dist/esm/Migrator/FileSystem.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"FileSystem.js","names":["FileSystem","Effect","Option","MigrationError","fromFileSystem","directory","pipe","flatMap","FS","readDirectory","mapError","error","reason","message","map","files","file","fromNullable","match","onNone","onSome","basename","id","name","Number","promise","sort","a","b"],"sources":["../../../src/Migrator/FileSystem.ts"],"sourcesContent":[null],"mappings":"AAAA;;;AAGA,SAASA,UAAU,QAAQ,6BAA6B;AACxD,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,MAAM,MAAM,eAAe;AAEvC,SAASC,cAAc,QAAQ,gBAAgB;AAE/C;;;;AAIA,OAAO,MAAMC,cAAc,GAAIC,SAAiB,IAC9CL,UAAU,CAACM,IAAI,CACbL,MAAM,CAACM,OAAO,CAAEC,EAAE,IAAKA,EAAE,CAACC,aAAa,CAACJ,SAAS,CAAC,CAAC,EACnDJ,MAAM,CAACS,QAAQ,CAAEC,KAAK,IAAK,IAAIR,cAAc,CAAC;EAAES,MAAM,EAAE,QAAQ;EAAEC,OAAO,EAAEF,KAAK,CAACE;AAAO,CAAE,CAAC,CAAC,EAC5FZ,MAAM,CAACa,GAAG,CAAEC,KAAK,IACfA,KAAK,CACFD,GAAG,CAAEE,IAAI,IAAKd,MAAM,CAACe,YAAY,CAACD,IAAI,CAACE,KAAK,CAAC,mCAAmC,CAAC,CAAC,CAAC,CACnFX,OAAO,CACNL,MAAM,CAACgB,KAAK,CAAC;EACXC,MAAM,EAAEA,CAAA,KAAM,EAAE;EAChBC,MAAM,EAAEA,CAAC,CAACC,QAAQ,EAAEC,EAAE,EAAEC,IAAI,CAAC,KAC3B,CACE,CACEC,MAAM,CAACF,EAAE,CAAC,EACVC,IAAI,EACJtB,MAAM,CAACwB,OAAO,CACZ,MACE,MAAM,EACJ;EACA,GAAGpB,SAAS,IAAIgB,QAAQ,EAAE,CAC3B,CACJ,CACF;CAEN,CAAC,CACH,CACAK,IAAI,CAAC,CAAC,CAACC,CAAC,CAAC,EAAE,CAACC,CAAC,CAAC,KAAKD,CAAC,GAAGC,CAAC,CAAC,CAC7B,CACF","ignoreList":[]}
+{"version":3,"file":"FileSystem.js","names":["FileSystem","Effect","Option","MigrationError","fromFileSystem","directory","pipe","flatMap","FS","readDirectory","mapError","error","reason","message","map","files","file","fromNullable","match","onNone","onSome","basename","id","name","Number","promise","sort","a","b"],"sources":["../../../src/Migrator/FileSystem.ts"],"sourcesContent":[null],"mappings":"AAAA;;;AAGA,SAASA,UAAU,QAAQ,6BAA6B;AACxD,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,MAAM,MAAM,eAAe;AAEvC,SAASC,cAAc,QAAQ,gBAAgB;AAE/C;;;;AAIA,OAAO,MAAMC,cAAc,GAAIC,SAAiB,IAC9CL,UAAU,CAACM,IAAI,CACbL,MAAM,CAACM,OAAO,CAAEC,EAAE,IAAKA,EAAE,CAACC,aAAa,CAACJ,SAAS,CAAC,CAAC,EACnDJ,MAAM,CAACS,QAAQ,CAAEC,KAAK,IAAK,IAAIR,cAAc,CAAC;EAAES,MAAM,EAAE,QAAQ;EAAEC,OAAO,EAAEF,KAAK,CAACE;AAAO,CAAE,CAAC,CAAC,EAC5FZ,MAAM,CAACa,GAAG,CAAEC,KAAK,IACfA,KAAK,CACFD,GAAG,CAAEE,IAAI,IAAKd,MAAM,CAACe,YAAY,CAACD,IAAI,CAACE,KAAK,CAAC,mCAAmC,CAAC,CAAC,CAAC,CACnFX,OAAO,CACNL,MAAM,CAACgB,KAAK,CAAC;EACXC,MAAM,EAAEA,CAAA,KAAM,EAAE;EAChBC,MAAM,EAAEA,CAAC,CAACC,QAAQ,EAAEC,EAAE,EAAEC,IAAI,CAAC,KAC3B,CACE,CACEC,MAAM,CAACF,EAAE,CAAC,EACVC,IAAI,EACJtB,MAAM,CAACwB,OAAO,CACZ,MACE,MAAM,EACJ;EACA;EACA,GAAGpB,SAAS,IAAIgB,QAAQ,EAAE,CAC3B,CACJ,CACF;CAEN,CAAC,CACH,CACAK,IAAI,CAAC,CAAC,CAACC,CAAC,CAAC,EAAE,CAACC,CAAC,CAAC,KAAKD,CAAC,GAAGC,CAAC,CAAC,CAC7B,CACF","ignoreList":[]}

dist/esm/Model.js

@@ -359,6 +359,11 @@ /**
   const idSchema = Model.fields[options.idColumn];
+  const idColumn = options.idColumn;
   const insertSchema = SqlSchema.single({
     Request: Model.insert,
     Result: Model,
-    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    execute: request => sql.onDialectOrElse({
+      mysql: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request)};
+select * from ${sql(options.tableName)} where ${sql(idColumn)} = LAST_INSERT_ID();`.unprepared.pipe(Effect.map(([, results]) => results)),
+      orElse: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    })
   });
@@ -371,6 +376,19 @@ const insert = insert => insertSchema(insert).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.insert`, {
   }));
+  const insertVoidSchema = SqlSchema.void({
+    Request: Model.insert,
+    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request)}`
+  });
+  const insertVoid = insert => insertVoidSchema(insert).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.insertVoid`, {
+    captureStackTrace: false,
+    attributes: {
+      insert
+    }
+  }));
   const updateSchema = SqlSchema.single({
     Request: Model.update,
     Result: Model,
-    execute: request => sql`update ${sql(options.tableName)} set ${sql.update(request, [options.idColumn])} where ${sql(options.idColumn)} = ${sql(request[options.idColumn])} returning *`
+    execute: request => sql.onDialectOrElse({
+      mysql: () => sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${request[idColumn]}`.raw.pipe(Effect.zipRight(sql`select * from ${sql(options.tableName)} where ${sql(options.idColumn)} = ${request[idColumn]}`), sql.withTransaction),
+      orElse: () => sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${request[idColumn]} returning *`
+    })
   });
@@ -383,6 +401,16 @@ const update = update => updateSchema(update).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.update`, {
   }));
+  const updateVoidSchema = SqlSchema.void({
+    Request: Model.update,
+    execute: request => sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${request[idColumn]}`
+  });
+  const updateVoid = update => updateVoidSchema(update).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.updateVoid`, {
+    captureStackTrace: false,
+    attributes: {
+      update
+    }
+  }));
   const findByIdSchema = SqlSchema.findOne({
     Request: idSchema,
     Result: Model,
-    execute: id => sql`select * from ${sql(options.tableName)} where ${sql(options.idColumn)} = ${id}`
+    execute: id => sql`select * from ${sql(options.tableName)} where ${sql(idColumn)} = ${id}`
   });
@@ -397,3 +425,3 @@ const findById = id => findByIdSchema(id).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.findById`, {
     Request: idSchema,
-    execute: id => sql`delete from ${sql(options.tableName)} where ${sql(options.idColumn)} = ${id}`
+    execute: id => sql`delete from ${sql(options.tableName)} where ${sql(idColumn)} = ${id}`
   });
@@ -408,3 +436,5 @@ const delete_ = id => deleteSchema(id).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.delete`, {
     insert,
+    insertVoid,
     update,
+    updateVoid,
     findById,
@@ -423,6 +453,13 @@ delete: delete_
   const idSchema = Model.fields[options.idColumn];
+  const idColumn = options.idColumn;
   const insertResolver = yield* SqlResolver.ordered(`${options.spanPrefix}/insert`, {
     Request: Model.insert,
     Result: Model,
-    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    execute: request => sql.onDialectOrElse({
+      mysql: () => Effect.forEach(request, request => sql`insert into ${sql(options.tableName)} ${sql.insert(request)};
+select * from ${sql(options.tableName)} where ${sql(idColumn)} = LAST_INSERT_ID();`.unprepared.pipe(Effect.map(([, results]) => results[0])), {
+        concurrency: 10
+      }),
+      orElse: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+    })
   });
@@ -440,2 +477,17 @@ const insertLoader = yield* RRX.dataLoader(insertResolver, {
   }));
+  const insertVoidResolver = yield* SqlResolver.void(`${options.spanPrefix}/insertVoid`, {
+    Request: Model.insert,
+    execute: request => sql`insert into ${sql(options.tableName)} ${sql.insert(request)}`
+  });
+  const insertVoidLoader = yield* RRX.dataLoader(insertVoidResolver, {
+    window: options.window,
+    maxBatchSize: options.maxBatchSize
+  });
+  const insertVoidExecute = insertVoidResolver.makeExecute(insertVoidLoader);
+  const insertVoid = insert => insertVoidExecute(insert).pipe(Effect.orDie, Effect.withSpan(`${options.spanPrefix}.insertVoid`, {
+    captureStackTrace: false,
+    attributes: {
+      insert
+    }
+  }));
   const findByIdResolver = yield* SqlResolver.grouped(`${options.spanPrefix}/findById`, {
@@ -448,5 +500,5 @@ Request: idSchema,
     ResultGroupKey(request) {
-      return request[options.idColumn];
+      return request[idColumn];
     },
-    execute: ids => sql`select * from ${sql(options.tableName)} where ${sql.in(options.idColumn, ids)}`
+    execute: ids => sql`select * from ${sql(options.tableName)} where ${sql.in(idColumn, ids)}`
   });
@@ -466,3 +518,3 @@ const findByIdLoader = yield* RRX.dataLoader(findByIdResolver, {
     Request: idSchema,
-    execute: ids => sql`delete from ${sql(options.tableName)} where ${sql.in(options.idColumn, ids)}`
+    execute: ids => sql`delete from ${sql(options.tableName)} where ${sql.in(idColumn, ids)}`
   });
@@ -482,2 +534,3 @@ const deleteLoader = yield* RRX.dataLoader(deleteResolver, {
     insert,
+    insertVoid,
     findById,
@@ -484,0 +537,0 @@ delete: delete_

dist/esm/Model.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"Model.js","names":["RRX","VariantSchema","ParseResult","Schema","DateTime","Effect","Option","SqlClient","SqlResolver","SqlSchema","Class","Field","FieldExcept","FieldOnly","Struct","Union","extract","fieldEvolve","make","variants","defaultVariant","fields","Override","Generated","schema","select","update","json","GeneratedByApp","insert","Sensitive","FieldOption","OptionFromNullOr","optionalWith","as","jsonCreate","nullable","jsonUpdate","DateTimeFromDate","transform","ValidDateFromSelf","DateTimeUtcFromSelf","decode","unsafeFromDate","encode","toDateUtc","Date","transformOrFail","String","s","_","ast","pipe","map","removeTime","match","onNone","fail","Type","onSome","dt","succeed","formatIsoDate","DateWithNow","Overrideable","generate","now","DateTimeWithNow","formatIso","DateTimeFromDateWithNow","DateFromSelf","DateTimeFromNumberWithNow","Number","toEpochMillis","DateTimeInsert","DateTimeUtc","DateTimeInsertFromDate","DateTimeInsertFromNumber","DateTimeUtcFromNumber","DateTimeUpdate","DateTimeUpdateFromDate","DateTimeUpdateFromNumber","JsonFromString","parsed","parseJson","makeRepository","Model","options","gen","sql","idSchema","idColumn","insertSchema","single","Request","Result","execute","request","tableName","returning","orDie","withSpan","spanPrefix","captureStackTrace","attributes","updateSchema","findByIdSchema","findOne","id","findById","deleteSchema","void","delete_","delete","makeDataLoaders","insertResolver","ordered","insertLoader","dataLoader","window","maxBatchSize","insertExecute","makeExecute","findByIdResolver","grouped","RequestGroupKey","ResultGroupKey","ids","in","findByIdLoader","findByIdExecute","deleteResolver","deleteLoader","deleteExecute"],"sources":["../../src/Model.ts"],"sourcesContent":[null],"mappings":"AAAA;;;AAGA,OAAO,KAAKA,GAAG,MAAM,sCAAsC;AAC3D,OAAO,KAAKC,aAAa,MAAM,oCAAoC;AACnE,OAAO,KAAKC,WAAW,MAAM,4BAA4B;AACzD,OAAO,KAAKC,MAAM,MAAM,uBAAuB;AAE/C,OAAO,KAAKC,QAAQ,MAAM,iBAAiB;AAE3C,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,MAAM,MAAM,eAAe;AAEvC,SAASC,SAAS,QAAQ,gBAAgB;AAC1C,OAAO,KAAKC,WAAW,MAAM,kBAAkB;AAC/C,OAAO,KAAKC,SAAS,MAAM,gBAAgB;AAE3C,MAAM;EACJC,KAAK;EACLC,KAAK;EACLC,WAAW;EACXC,SAAS;EACTC,MAAM;EACNC,KAAK;EACLC,OAAO;EACPC;AAAW,CACZ,gBAAGhB,aAAa,CAACiB,IAAI,CAAC;EACrBC,QAAQ,EAAE,CAAC,QAAQ,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,EAAE,YAAY,EAAE,YAAY,CAAC;EAC5EC,cAAc,EAAE;CACjB,CAAC;AAwCF;AACE;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAyCAV,KAAK;AACL;;;;AAIAM,OAAO;AACP;;;;AAIAL,KAAK;AACL;;;;AAIAM,WAAW;AACX;;;;AAIAL,WAAW;AACX;;;;AAIAC,SAAS;AACT;;;;AAIAC,MAAM;AACN;;;;AAIAC,KAAK;AAGP;;;;AAIA,OAAO,MAAMM,MAAM,GAA8EpB,aAAa,CAACoB,MAAM;AAErH;;;;AAIA,OAAO,MAAMC,QAAQ,GAA2CrB,aAAa,CAACqB,QAAQ;AActF;;;;;;;;AAQA,OAAO,MAAMC,SAAS,GACpBC,MAAS,IAETb,KAAK,CAAC;EACJc,MAAM,EAAED,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAgBJ;;;;;;;;AAQA,OAAO,MAAMI,cAAc,GACzBJ,MAAS,IAETb,KAAK,CAAC;EACJc,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAcJ;;;;;;;AAOA,OAAO,MAAMM,SAAS,GACpBN,MAAS,IAETb,KAAK,CAAC;EACJc,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF;CACT,CAAC;AAsBJ;;;;;;;;;AASA,OAAO,MAAMO,WAAW,gBAWdd,WAAW,CAAC;EAClBQ,MAAM,EAAEtB,MAAM,CAAC6B,gBAAgB;EAC/BH,MAAM,EAAE1B,MAAM,CAAC6B,gBAAgB;EAC/BN,MAAM,EAAEvB,MAAM,CAAC6B,gBAAgB;EAC/BL,IAAI,eAAExB,MAAM,CAAC8B,YAAY,CAAC;IAAEC,EAAE,EAAE;EAAQ,CAAE,CAAC;EAC3CC,UAAU,eAAEhC,MAAM,CAAC8B,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE,CAAC;EACjEC,UAAU,eAAElC,MAAM,CAAC8B,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE;CACjE,CAAQ;AAaX;;;;AAIA,OAAO,MAAME,gBAAgB,gBAAqBnC,MAAM,CAACoC,SAAS,CAChEpC,MAAM,CAACqC,iBAAiB,EACxBrC,MAAM,CAACsC,mBAAmB,EAC1B;EACEC,MAAM,EAAEtC,QAAQ,CAACuC,cAAc;EAC/BC,MAAM,EAAExC,QAAQ,CAACyC;CAClB,CACF;AAQD;;;;;;;AAOA,OAAO,MAAMC,IAAI,gBAAS3C,MAAM,CAAC4C,eAAe,CAC9C5C,MAAM,CAAC6C,MAAM,EACb7C,MAAM,CAACsC,mBAAmB,EAC1B;EACEC,MAAM,EAAEA,CAACO,CAAC,EAAEC,CAAC,EAAEC,GAAG,KAChB/C,QAAQ,CAACc,IAAI,CAAC+B,CAAC,CAAC,CAACG,IAAI,CACnB9C,MAAM,CAAC+C,GAAG,CAACjD,QAAQ,CAACkD,UAAU,CAAC,EAC/BhD,MAAM,CAACiD,KAAK,CAAC;IACXC,MAAM,EAAEA,CAAA,KAAMtD,WAAW,CAACuD,IAAI,CAAC,IAAIvD,WAAW,CAACwD,IAAI,CAACP,GAAG,EAAEF,CAAC,CAAC,CAAC;IAC5DU,MAAM,EAAGC,EAAE,IAAK1D,WAAW,CAAC2D,OAAO,CAACD,EAAE;GACvC,CAAC,CACH;EACHhB,MAAM,EAAGgB,EAAE,IAAK1D,WAAW,CAAC2D,OAAO,CAACzD,QAAQ,CAAC0D,aAAa,CAACF,EAAE,CAAC;CAC/D,CACF;AAED;;;;AAIA,OAAO,MAAMG,WAAW,gBAAG9D,aAAa,CAAC+D,YAAY,CAAClB,IAAI,EAAE3C,MAAM,CAACsC,mBAAmB,EAAE;EACtFwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACkD,UAAU,CAAC;IAC3DK,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACkD,UAAU,CAACM,EAAE,CAAC;GACvD;CACF,CAAC;AAEF;;;;AAIA,OAAO,MAAMO,eAAe,gBAAGlE,aAAa,CAAC+D,YAAY,CAAC7D,MAAM,CAAC6C,MAAM,EAAE7C,MAAM,CAACsC,mBAAmB,EAAE;EACnGwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACgE,SAAS,CAAC;IAC1DT,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACgE,SAAS,CAACR,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIA,OAAO,MAAMS,uBAAuB,gBAAGpE,aAAa,CAAC+D,YAAY,CAAC7D,MAAM,CAACmE,YAAY,EAAEnE,MAAM,CAACsC,mBAAmB,EAAE;EACjHwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACyC,SAAS,CAAC;IAC1Dc,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACyC,SAAS,CAACe,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIA,OAAO,MAAMW,yBAAyB,gBAAGtE,aAAa,CAAC+D,YAAY,CAAC7D,MAAM,CAACqE,MAAM,EAAErE,MAAM,CAACsC,mBAAmB,EAAE;EAC7GwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACqE,aAAa,CAAC;IAC9Dd,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACqE,aAAa,CAACb,EAAE,CAAC;GAC1D;CACF,CAAC;AAcF;;;;;;;;;AASA,OAAO,MAAMc,cAAc,gBAAmB/D,KAAK,CAAC;EAClDc,MAAM,EAAEtB,MAAM,CAACwE,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBxC,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAcF;;;;;;;;;AASA,OAAO,MAAMC,sBAAsB,gBAA2BjE,KAAK,CAAC;EAClEc,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B1C,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAcF;;;;;;;;;AASA,OAAO,MAAME,wBAAwB,gBAA6BlE,KAAK,CAAC;EACtEc,MAAM,EAAEtB,MAAM,CAAC2E,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC5C,IAAI,EAAExB,MAAM,CAAC2E;CACd,CAAC;AAeF;;;;;;;;;;AAUA,OAAO,MAAMC,cAAc,gBAAmBpE,KAAK,CAAC;EAClDc,MAAM,EAAEtB,MAAM,CAACwE,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBzC,MAAM,EAAEyC,eAAe;EACvBxC,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAeF;;;;;;;;;;AAUA,OAAO,MAAMK,sBAAsB,gBAA2BrE,KAAK,CAAC;EAClEc,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B3C,MAAM,EAAE2C,uBAAuB;EAC/B1C,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAeF;;;;;;;;;;AAUA,OAAO,MAAMM,wBAAwB,gBAA6BtE,KAAK,CAAC;EACtEc,MAAM,EAAEtB,MAAM,CAAC2E,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC7C,MAAM,EAAE6C,yBAAyB;EACjC5C,IAAI,EAAExB,MAAM,CAAC2E;CACd,CAAC;AAkBF;;;;;;;;AAQA,OAAO,MAAMI,cAAc,GACzB1D,MAAS,IACY;EACrB,MAAM2D,MAAM,GAAGhF,MAAM,CAACiF,SAAS,CAAC5D,MAAa,CAAC;EAC9C,OAAOb,KAAK,CAAC;IACXc,MAAM,EAAE0D,MAAM;IACdtD,MAAM,EAAEsD,MAAM;IACdzD,MAAM,EAAEyD,MAAM;IACdxD,IAAI,EAAEH,MAAM;IACZW,UAAU,EAAEX,MAAM;IAClBa,UAAU,EAAEb;GACb,CAAQ;AACX,CAAC;AAED;;;;;;AAMA,OAAO,MAAM6D,cAAc,GAAGA,CAG5BC,KAAQ,EAAEC,OAIX,KAkBClF,MAAM,CAACmF,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOlF,SAAS;EAC5B,MAAMmF,QAAQ,GAAGJ,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACI,QAAQ,CAAsB;EAEpE,MAAMC,YAAY,GAAGnF,SAAS,CAACoF,MAAM,CAAC;IACpCC,OAAO,EAAER,KAAK,CAACzD,MAAM;IACrBkE,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGC,OAAO,IAAKR,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACW,SAAS,CAAC,IAAIT,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC,CAACE,SAAS,CAAC,GAAG,CAAC;GACrG,CAAC;EACF,MAAMtE,MAAM,GACVA,MAA2B,IAE3B+D,YAAY,CAAC/D,MAAM,CAAC,CAACuB,IAAI,CACvB/C,MAAM,CAAC+F,KAAK,EACZ/F,MAAM,CAACgG,QAAQ,CAAC,GAAGd,OAAO,CAACe,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAE3E;IAAM;GACrB,CAAC,CACI;EAEV,MAAM4E,YAAY,GAAGhG,SAAS,CAACoF,MAAM,CAAC;IACpCC,OAAO,EAAER,KAAK,CAAC5D,MAAM;IACrBqE,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGC,OAAO,IACfR,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACW,SAAS,CAAC,QAAQT,GAAG,CAAC/D,MAAM,CAACuE,OAAO,EAAE,CAACV,OAAO,CAACI,QAAQ,CAAC,CAAC,UAChFF,GAAG,CAACF,OAAO,CAACI,QAAkB,CAChC,MAAMF,GAAG,CAACQ,OAAO,CAACV,OAAO,CAACI,QAAQ,CAAC,CAAC;GACvC,CAAC;EACF,MAAMjE,MAAM,GACVA,MAA2B,IAE3B+E,YAAY,CAAC/E,MAAM,CAAC,CAAC0B,IAAI,CACvB/C,MAAM,CAAC+F,KAAK,EACZ/F,MAAM,CAACgG,QAAQ,CAAC,GAAGd,OAAO,CAACe,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAE9E;IAAM;GACrB,CAAC,CACI;EAEV,MAAMgF,cAAc,GAAGjG,SAAS,CAACkG,OAAO,CAAC;IACvCb,OAAO,EAAEJ,QAAQ;IACjBK,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGY,EAAE,IAAKnB,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACW,SAAS,CAAC,UAAUT,GAAG,CAACF,OAAO,CAACI,QAAkB,CAAC,MAAMiB,EAAE;GAC7G,CAAC;EACF,MAAMC,QAAQ,GACZD,EAAuC,IAEvCF,cAAc,CAACE,EAAE,CAAC,CAACxD,IAAI,CACrB/C,MAAM,CAAC+F,KAAK,EACZ/F,MAAM,CAACgG,QAAQ,CAAC,GAAGd,OAAO,CAACe,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,MAAME,YAAY,GAAGrG,SAAS,CAACsG,IAAI,CAAC;IAClCjB,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAGY,EAAE,IAAKnB,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACW,SAAS,CAAC,UAAUT,GAAG,CAACF,OAAO,CAACI,QAAkB,CAAC,MAAMiB,EAAE;GAC3G,CAAC;EACF,MAAMI,OAAO,GACXJ,EAAuC,IAEvCE,YAAY,CAACF,EAAE,CAAC,CAACxD,IAAI,CACnB/C,MAAM,CAAC+F,KAAK,EACZ/F,MAAM,CAACgG,QAAQ,CAAC,GAAGd,OAAO,CAACe,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAE/E,MAAM;IAAEH,MAAM;IAAEmF,QAAQ;IAAEI,MAAM,EAAED;EAAO,CAAW;AAC/D,CAAC,CAAC;AAEJ;;;;;;AAMA,OAAO,MAAME,eAAe,GAAGA,CAI7B5B,KAAQ,EACRC,OAMC,KAUDlF,MAAM,CAACmF,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOlF,SAAS;EAC5B,MAAMmF,QAAQ,GAAGJ,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACI,QAAQ,CAAsB;EAEpE,MAAMwB,cAAc,GAAG,OAAO3G,WAAW,CAAC4G,OAAO,CAAC,GAAG7B,OAAO,CAACe,UAAU,SAAS,EAAE;IAChFR,OAAO,EAAER,KAAK,CAACzD,MAAM;IACrBkE,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGC,OAAO,IAAKR,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACW,SAAS,CAAC,IAAIT,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC,CAACE,SAAS,CAAC,GAAG,CAAC;GACrG,CAAC;EACF,MAAMkB,YAAY,GAAG,OAAOrH,GAAG,CAACsH,UAAU,CAACH,cAAc,EAAE;IACzDI,MAAM,EAAEhC,OAAO,CAACgC,MAAM;IACtBC,YAAY,EAAEjC,OAAO,CAACiC;GACvB,CAAC;EACF,MAAMC,aAAa,GAAGN,cAAc,CAACO,WAAW,CAACL,YAAY,CAAC;EAC9D,MAAMxF,MAAM,GACVA,MAA2B,IAE3B4F,aAAa,CAAC5F,MAAM,CAAC,CAACuB,IAAI,CACxB/C,MAAM,CAAC+F,KAAK,EACZ/F,MAAM,CAACgG,QAAQ,CAAC,GAAGd,OAAO,CAACe,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAE3E;IAAM;GACrB,CAAC,CACI;EAEV,MAAM8F,gBAAgB,GAAG,OAAOnH,WAAW,CAACoH,OAAO,CAAC,GAAGrC,OAAO,CAACe,UAAU,WAAW,EAAE;IACpFR,OAAO,EAAEJ,QAAQ;IACjBmC,eAAeA,CAACjB,EAAE;MAChB,OAAOA,EAAE;IACX,CAAC;IACDb,MAAM,EAAET,KAAK;IACbwC,cAAcA,CAAC7B,OAAO;MACpB,OAAOA,OAAO,CAACV,OAAO,CAACI,QAAQ,CAAC;IAClC,CAAC;IACDK,OAAO,EAAG+B,GAAG,IAAKtC,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACW,SAAS,CAAC,UAAUT,GAAG,CAACuC,EAAE,CAACzC,OAAO,CAACI,QAAkB,EAAEoC,GAAG,CAAC;GAC9G,CAAC;EACF,MAAME,cAAc,GAAG,OAAOjI,GAAG,CAACsH,UAAU,CAACK,gBAAgB,EAAE;IAC7DJ,MAAM,EAAEhC,OAAO,CAACgC,MAAM;IACtBC,YAAY,EAAEjC,OAAO,CAACiC;GACvB,CAAC;EACF,MAAMU,eAAe,GAAGP,gBAAgB,CAACD,WAAW,CAACO,cAAc,CAAC;EACpE,MAAMpB,QAAQ,GAAID,EAAuC,IACvDsB,eAAe,CAACtB,EAAE,CAAC,CAACxD,IAAI,CACtB/C,MAAM,CAAC+F,KAAK,EACZ/F,MAAM,CAACgG,QAAQ,CAAC,GAAGd,OAAO,CAACe,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,MAAMuB,cAAc,GAAG,OAAO3H,WAAW,CAACuG,IAAI,CAAC,GAAGxB,OAAO,CAACe,UAAU,SAAS,EAAE;IAC7ER,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAG+B,GAAG,IAAKtC,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACW,SAAS,CAAC,UAAUT,GAAG,CAACuC,EAAE,CAACzC,OAAO,CAACI,QAAkB,EAAEoC,GAAG,CAAC;GAC5G,CAAC;EACF,MAAMK,YAAY,GAAG,OAAOpI,GAAG,CAACsH,UAAU,CAACa,cAAc,EAAE;IACzDZ,MAAM,EAAEhC,OAAO,CAACgC,MAAM;IACtBC,YAAY,EAAEjC,OAAO,CAACiC;GACvB,CAAC;EACF,MAAMa,aAAa,GAAGF,cAAc,CAACT,WAAW,CAACU,YAAY,CAAC;EAC9D,MAAMpB,OAAO,GAAIJ,EAAuC,IACtDyB,aAAa,CAACzB,EAAE,CAAC,CAACxD,IAAI,CACpB/C,MAAM,CAAC+F,KAAK,EACZ/F,MAAM,CAACgG,QAAQ,CAAC,GAAGd,OAAO,CAACe,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEI;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAE/E,MAAM;IAAEgF,QAAQ;IAAEI,MAAM,EAAED;EAAO,CAAW;AACvD,CAAC,CAAC","ignoreList":[]}
+{"version":3,"file":"Model.js","names":["RRX","VariantSchema","ParseResult","Schema","DateTime","Effect","Option","SqlClient","SqlResolver","SqlSchema","Class","Field","FieldExcept","FieldOnly","Struct","Union","extract","fieldEvolve","make","variants","defaultVariant","fields","Override","Generated","schema","select","update","json","GeneratedByApp","insert","Sensitive","FieldOption","OptionFromNullOr","optionalWith","as","jsonCreate","nullable","jsonUpdate","DateTimeFromDate","transform","ValidDateFromSelf","DateTimeUtcFromSelf","decode","unsafeFromDate","encode","toDateUtc","Date","transformOrFail","String","s","_","ast","pipe","map","removeTime","match","onNone","fail","Type","onSome","dt","succeed","formatIsoDate","DateWithNow","Overrideable","generate","now","DateTimeWithNow","formatIso","DateTimeFromDateWithNow","DateFromSelf","DateTimeFromNumberWithNow","Number","toEpochMillis","DateTimeInsert","DateTimeUtc","DateTimeInsertFromDate","DateTimeInsertFromNumber","DateTimeUtcFromNumber","DateTimeUpdate","DateTimeUpdateFromDate","DateTimeUpdateFromNumber","JsonFromString","parsed","parseJson","makeRepository","Model","options","gen","sql","idSchema","idColumn","insertSchema","single","Request","Result","execute","request","onDialectOrElse","mysql","tableName","unprepared","results","orElse","returning","orDie","withSpan","spanPrefix","captureStackTrace","attributes","insertVoidSchema","void","insertVoid","updateSchema","raw","zipRight","withTransaction","updateVoidSchema","updateVoid","findByIdSchema","findOne","id","findById","deleteSchema","delete_","delete","makeDataLoaders","insertResolver","ordered","forEach","concurrency","insertLoader","dataLoader","window","maxBatchSize","insertExecute","makeExecute","insertVoidResolver","insertVoidLoader","insertVoidExecute","findByIdResolver","grouped","RequestGroupKey","ResultGroupKey","ids","in","findByIdLoader","findByIdExecute","deleteResolver","deleteLoader","deleteExecute"],"sources":["../../src/Model.ts"],"sourcesContent":[null],"mappings":"AAAA;;;AAGA,OAAO,KAAKA,GAAG,MAAM,sCAAsC;AAC3D,OAAO,KAAKC,aAAa,MAAM,oCAAoC;AACnE,OAAO,KAAKC,WAAW,MAAM,4BAA4B;AACzD,OAAO,KAAKC,MAAM,MAAM,uBAAuB;AAE/C,OAAO,KAAKC,QAAQ,MAAM,iBAAiB;AAE3C,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,MAAM,MAAM,eAAe;AAEvC,SAASC,SAAS,QAAQ,gBAAgB;AAC1C,OAAO,KAAKC,WAAW,MAAM,kBAAkB;AAC/C,OAAO,KAAKC,SAAS,MAAM,gBAAgB;AAE3C,MAAM;EACJC,KAAK;EACLC,KAAK;EACLC,WAAW;EACXC,SAAS;EACTC,MAAM;EACNC,KAAK;EACLC,OAAO;EACPC;AAAW,CACZ,gBAAGhB,aAAa,CAACiB,IAAI,CAAC;EACrBC,QAAQ,EAAE,CAAC,QAAQ,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,EAAE,YAAY,EAAE,YAAY,CAAC;EAC5EC,cAAc,EAAE;CACjB,CAAC;AAwCF;AACE;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAyCAV,KAAK;AACL;;;;AAIAM,OAAO;AACP;;;;AAIAL,KAAK;AACL;;;;AAIAM,WAAW;AACX;;;;AAIAL,WAAW;AACX;;;;AAIAC,SAAS;AACT;;;;AAIAC,MAAM;AACN;;;;AAIAC,KAAK;AAGP;;;;AAIA,OAAO,MAAMM,MAAM,GAA8EpB,aAAa,CAACoB,MAAM;AAErH;;;;AAIA,OAAO,MAAMC,QAAQ,GAA2CrB,aAAa,CAACqB,QAAQ;AActF;;;;;;;;AAQA,OAAO,MAAMC,SAAS,GACpBC,MAAS,IAETb,KAAK,CAAC;EACJc,MAAM,EAAED,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAgBJ;;;;;;;;AAQA,OAAO,MAAMI,cAAc,GACzBJ,MAAS,IAETb,KAAK,CAAC;EACJc,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF,MAAM;EACdG,IAAI,EAAEH;CACP,CAAC;AAcJ;;;;;;;AAOA,OAAO,MAAMM,SAAS,GACpBN,MAAS,IAETb,KAAK,CAAC;EACJc,MAAM,EAAED,MAAM;EACdK,MAAM,EAAEL,MAAM;EACdE,MAAM,EAAEF;CACT,CAAC;AAsBJ;;;;;;;;;AASA,OAAO,MAAMO,WAAW,gBAWdd,WAAW,CAAC;EAClBQ,MAAM,EAAEtB,MAAM,CAAC6B,gBAAgB;EAC/BH,MAAM,EAAE1B,MAAM,CAAC6B,gBAAgB;EAC/BN,MAAM,EAAEvB,MAAM,CAAC6B,gBAAgB;EAC/BL,IAAI,eAAExB,MAAM,CAAC8B,YAAY,CAAC;IAAEC,EAAE,EAAE;EAAQ,CAAE,CAAC;EAC3CC,UAAU,eAAEhC,MAAM,CAAC8B,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE,CAAC;EACjEC,UAAU,eAAElC,MAAM,CAAC8B,YAAY,CAAC;IAAEC,EAAE,EAAE,QAAQ;IAAEE,QAAQ,EAAE;EAAI,CAAE;CACjE,CAAQ;AAaX;;;;AAIA,OAAO,MAAME,gBAAgB,gBAAqBnC,MAAM,CAACoC,SAAS,CAChEpC,MAAM,CAACqC,iBAAiB,EACxBrC,MAAM,CAACsC,mBAAmB,EAC1B;EACEC,MAAM,EAAEtC,QAAQ,CAACuC,cAAc;EAC/BC,MAAM,EAAExC,QAAQ,CAACyC;CAClB,CACF;AAQD;;;;;;;AAOA,OAAO,MAAMC,IAAI,gBAAS3C,MAAM,CAAC4C,eAAe,CAC9C5C,MAAM,CAAC6C,MAAM,EACb7C,MAAM,CAACsC,mBAAmB,EAC1B;EACEC,MAAM,EAAEA,CAACO,CAAC,EAAEC,CAAC,EAAEC,GAAG,KAChB/C,QAAQ,CAACc,IAAI,CAAC+B,CAAC,CAAC,CAACG,IAAI,CACnB9C,MAAM,CAAC+C,GAAG,CAACjD,QAAQ,CAACkD,UAAU,CAAC,EAC/BhD,MAAM,CAACiD,KAAK,CAAC;IACXC,MAAM,EAAEA,CAAA,KAAMtD,WAAW,CAACuD,IAAI,CAAC,IAAIvD,WAAW,CAACwD,IAAI,CAACP,GAAG,EAAEF,CAAC,CAAC,CAAC;IAC5DU,MAAM,EAAGC,EAAE,IAAK1D,WAAW,CAAC2D,OAAO,CAACD,EAAE;GACvC,CAAC,CACH;EACHhB,MAAM,EAAGgB,EAAE,IAAK1D,WAAW,CAAC2D,OAAO,CAACzD,QAAQ,CAAC0D,aAAa,CAACF,EAAE,CAAC;CAC/D,CACF;AAED;;;;AAIA,OAAO,MAAMG,WAAW,gBAAG9D,aAAa,CAAC+D,YAAY,CAAClB,IAAI,EAAE3C,MAAM,CAACsC,mBAAmB,EAAE;EACtFwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACkD,UAAU,CAAC;IAC3DK,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACkD,UAAU,CAACM,EAAE,CAAC;GACvD;CACF,CAAC;AAEF;;;;AAIA,OAAO,MAAMO,eAAe,gBAAGlE,aAAa,CAAC+D,YAAY,CAAC7D,MAAM,CAAC6C,MAAM,EAAE7C,MAAM,CAACsC,mBAAmB,EAAE;EACnGwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACgE,SAAS,CAAC;IAC1DT,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACgE,SAAS,CAACR,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIA,OAAO,MAAMS,uBAAuB,gBAAGpE,aAAa,CAAC+D,YAAY,CAAC7D,MAAM,CAACmE,YAAY,EAAEnE,MAAM,CAACsC,mBAAmB,EAAE;EACjHwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACyC,SAAS,CAAC;IAC1Dc,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACyC,SAAS,CAACe,EAAE,CAAC;GACtD;CACF,CAAC;AAEF;;;;AAIA,OAAO,MAAMW,yBAAyB,gBAAGtE,aAAa,CAAC+D,YAAY,CAAC7D,MAAM,CAACqE,MAAM,EAAErE,MAAM,CAACsC,mBAAmB,EAAE;EAC7GwB,QAAQ,eAAE3D,MAAM,CAACiD,KAAK,CAAC;IACrBC,MAAM,EAAEA,CAAA,KAAMnD,MAAM,CAACgD,GAAG,CAACjD,QAAQ,CAAC8D,GAAG,EAAE9D,QAAQ,CAACqE,aAAa,CAAC;IAC9Dd,MAAM,EAAGC,EAAE,IAAKvD,MAAM,CAACwD,OAAO,CAACzD,QAAQ,CAACqE,aAAa,CAACb,EAAE,CAAC;GAC1D;CACF,CAAC;AAcF;;;;;;;;;AASA,OAAO,MAAMc,cAAc,gBAAmB/D,KAAK,CAAC;EAClDc,MAAM,EAAEtB,MAAM,CAACwE,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBxC,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAcF;;;;;;;;;AASA,OAAO,MAAMC,sBAAsB,gBAA2BjE,KAAK,CAAC;EAClEc,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B1C,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAcF;;;;;;;;;AASA,OAAO,MAAME,wBAAwB,gBAA6BlE,KAAK,CAAC;EACtEc,MAAM,EAAEtB,MAAM,CAAC2E,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC5C,IAAI,EAAExB,MAAM,CAAC2E;CACd,CAAC;AAeF;;;;;;;;;;AAUA,OAAO,MAAMC,cAAc,gBAAmBpE,KAAK,CAAC;EAClDc,MAAM,EAAEtB,MAAM,CAACwE,WAAW;EAC1B9C,MAAM,EAAEsC,eAAe;EACvBzC,MAAM,EAAEyC,eAAe;EACvBxC,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAeF;;;;;;;;;;AAUA,OAAO,MAAMK,sBAAsB,gBAA2BrE,KAAK,CAAC;EAClEc,MAAM,EAAEa,gBAAgB;EACxBT,MAAM,EAAEwC,uBAAuB;EAC/B3C,MAAM,EAAE2C,uBAAuB;EAC/B1C,IAAI,EAAExB,MAAM,CAACwE;CACd,CAAC;AAeF;;;;;;;;;;AAUA,OAAO,MAAMM,wBAAwB,gBAA6BtE,KAAK,CAAC;EACtEc,MAAM,EAAEtB,MAAM,CAAC2E,qBAAqB;EACpCjD,MAAM,EAAE0C,yBAAyB;EACjC7C,MAAM,EAAE6C,yBAAyB;EACjC5C,IAAI,EAAExB,MAAM,CAAC2E;CACd,CAAC;AAkBF;;;;;;;;AAQA,OAAO,MAAMI,cAAc,GACzB1D,MAAS,IACY;EACrB,MAAM2D,MAAM,GAAGhF,MAAM,CAACiF,SAAS,CAAC5D,MAAa,CAAC;EAC9C,OAAOb,KAAK,CAAC;IACXc,MAAM,EAAE0D,MAAM;IACdtD,MAAM,EAAEsD,MAAM;IACdzD,MAAM,EAAEyD,MAAM;IACdxD,IAAI,EAAEH,MAAM;IACZW,UAAU,EAAEX,MAAM;IAClBa,UAAU,EAAEb;GACb,CAAQ;AACX,CAAC;AAED;;;;;;AAMA,OAAO,MAAM6D,cAAc,GAAGA,CAG5BC,KAAQ,EAAEC,OAIX,KAwBClF,MAAM,CAACmF,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOlF,SAAS;EAC5B,MAAMmF,QAAQ,GAAGJ,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACI,QAAQ,CAAsB;EACpE,MAAMA,QAAQ,GAAGJ,OAAO,CAACI,QAAkB;EAE3C,MAAMC,YAAY,GAAGnF,SAAS,CAACoF,MAAM,CAAC;IACpCC,OAAO,EAAER,KAAK,CAACzD,MAAM;IACrBkE,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGC,OAAO,IACfR,GAAG,CAACS,eAAe,CAAC;MAClBC,KAAK,EAAEA,CAAA,KACLV,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,IAAIX,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC;gBAC3DR,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,UAAUX,GAAG,CAACE,QAAQ,CAAC,sBAAsB,CAACU,UAAU,CAACjD,IAAI,CACrF/C,MAAM,CAACgD,GAAG,CAAC,CAAC,GAAGiD,OAAO,CAAC,KAAKA,OAAc,CAAC,CAC5C;MACHC,MAAM,EAAEA,CAAA,KAAMd,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,IAAIX,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC,CAACO,SAAS,CAAC,GAAG,CAAC;KAC7F;GACJ,CAAC;EACF,MAAM3E,MAAM,GACVA,MAA2B,IAE3B+D,YAAY,CAAC/D,MAAM,CAAC,CAACuB,IAAI,CACvB/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEhF;IAAM;GACrB,CAAC,CACI;EAEV,MAAMiF,gBAAgB,GAAGrG,SAAS,CAACsG,IAAI,CAAC;IACtCjB,OAAO,EAAER,KAAK,CAACzD,MAAM;IACrBmE,OAAO,EAAGC,OAAO,IAAKR,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,IAAIX,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC;GACtF,CAAC;EACF,MAAMe,UAAU,GACdnF,MAA2B,IAE3BiF,gBAAgB,CAACjF,MAAM,CAAC,CAACuB,IAAI,CAC3B/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,aAAa,EAAE;IAClDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEhF;IAAM;GACrB,CAAC,CACI;EAEV,MAAMoF,YAAY,GAAGxG,SAAS,CAACoF,MAAM,CAAC;IACpCC,OAAO,EAAER,KAAK,CAAC5D,MAAM;IACrBqE,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGC,OAAO,IACfR,GAAG,CAACS,eAAe,CAAC;MAClBC,KAAK,EAAEA,CAAA,KACLV,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,QAAQX,GAAG,CAAC/D,MAAM,CAACuE,OAAO,EAAE,CAACN,QAAQ,CAAC,CAAC,UAAUF,GAAG,CAACE,QAAQ,CAAC,MAC/FM,OAAO,CAACN,QAAQ,CAClB,EAAE,CAACuB,GAAG,CAAC9D,IAAI,CACT/C,MAAM,CAAC8G,QAAQ,CACb1B,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,UAAUX,GAAG,CAACF,OAAO,CAACI,QAAkB,CAAC,MACjFM,OAAO,CAACN,QAAQ,CAClB,EAAE,CACH,EACDF,GAAG,CAAC2B,eAAe,CACpB;MACHb,MAAM,EAAEA,CAAA,KACNd,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,QAAQX,GAAG,CAAC/D,MAAM,CAACuE,OAAO,EAAE,CAACN,QAAQ,CAAC,CAAC,UAAUF,GAAG,CAACE,QAAQ,CAAC,MAC/FM,OAAO,CAACN,QAAQ,CAClB;KACH;GACJ,CAAC;EACF,MAAMjE,MAAM,GACVA,MAA2B,IAE3BuF,YAAY,CAACvF,MAAM,CAAC,CAAC0B,IAAI,CACvB/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEnF;IAAM;GACrB,CAAC,CACI;EAEV,MAAM2F,gBAAgB,GAAG5G,SAAS,CAACsG,IAAI,CAAC;IACtCjB,OAAO,EAAER,KAAK,CAAC5D,MAAM;IACrBsE,OAAO,EAAGC,OAAO,IACfR,GAAG,UAAUA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,QAAQX,GAAG,CAAC/D,MAAM,CAACuE,OAAO,EAAE,CAACN,QAAQ,CAAC,CAAC,UAAUF,GAAG,CAACE,QAAQ,CAAC,MAC/FM,OAAO,CAACN,QAAQ,CAClB;GACH,CAAC;EACF,MAAM2B,UAAU,GACd5F,MAA2B,IAE3B2F,gBAAgB,CAAC3F,MAAM,CAAC,CAAC0B,IAAI,CAC3B/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,aAAa,EAAE;IAClDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEnF;IAAM;GACrB,CAAC,CACI;EAEV,MAAM6F,cAAc,GAAG9G,SAAS,CAAC+G,OAAO,CAAC;IACvC1B,OAAO,EAAEJ,QAAQ;IACjBK,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGyB,EAAE,IAAKhC,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,UAAUX,GAAG,CAACE,QAAQ,CAAC,MAAM8B,EAAE;GAC3F,CAAC;EACF,MAAMC,QAAQ,GACZD,EAAuC,IAEvCF,cAAc,CAACE,EAAE,CAAC,CAACrE,IAAI,CACrB/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,MAAME,YAAY,GAAGlH,SAAS,CAACsG,IAAI,CAAC;IAClCjB,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAGyB,EAAE,IAAKhC,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,UAAUX,GAAG,CAACE,QAAQ,CAAC,MAAM8B,EAAE;GACzF,CAAC;EACF,MAAMG,OAAO,GACXH,EAAuC,IAEvCE,YAAY,CAACF,EAAE,CAAC,CAACrE,IAAI,CACnB/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAE5F,MAAM;IAAEmF,UAAU;IAAEtF,MAAM;IAAE4F,UAAU;IAAEI,QAAQ;IAAEG,MAAM,EAAED;EAAO,CAAW;AACvF,CAAC,CAAC;AAEJ;;;;;;AAMA,OAAO,MAAME,eAAe,GAAGA,CAI7BxC,KAAQ,EACRC,OAMC,KAWDlF,MAAM,CAACmF,GAAG,CAAC,aAAS;EAClB,MAAMC,GAAG,GAAG,OAAOlF,SAAS;EAC5B,MAAMmF,QAAQ,GAAGJ,KAAK,CAACjE,MAAM,CAACkE,OAAO,CAACI,QAAQ,CAAsB;EACpE,MAAMA,QAAQ,GAAGJ,OAAO,CAACI,QAAkB;EAE3C,MAAMoC,cAAc,GAAG,OAAOvH,WAAW,CAACwH,OAAO,CAAC,GAAGzC,OAAO,CAACoB,UAAU,SAAS,EAAE;IAChFb,OAAO,EAAER,KAAK,CAACzD,MAAM;IACrBkE,MAAM,EAAET,KAAK;IACbU,OAAO,EAAGC,OAAO,IACfR,GAAG,CAACS,eAAe,CAAC;MAClBC,KAAK,EAAEA,CAAA,KACL9F,MAAM,CAAC4H,OAAO,CAAChC,OAAO,EAAGA,OAAO,IAC9BR,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,IAAIX,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC;gBAC7DR,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,UAAUX,GAAG,CAACE,QAAQ,CAAC,sBAAsB,CAACU,UAAU,CAACjD,IAAI,CACnF/C,MAAM,CAACgD,GAAG,CAAC,CAAC,GAAGiD,OAAO,CAAC,KAAKA,OAAO,CAAC,CAAC,CAAQ,CAAC,CAC/C,EAAE;QAAE4B,WAAW,EAAE;MAAE,CAAE,CAAC;MAC3B3B,MAAM,EAAEA,CAAA,KAAMd,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,IAAIX,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC,CAACO,SAAS,CAAC,GAAG,CAAC;KAC7F;GACJ,CAAC;EACF,MAAM2B,YAAY,GAAG,OAAOnI,GAAG,CAACoI,UAAU,CAACL,cAAc,EAAE;IACzDM,MAAM,EAAE9C,OAAO,CAAC8C,MAAM;IACtBC,YAAY,EAAE/C,OAAO,CAAC+C;GACvB,CAAC;EACF,MAAMC,aAAa,GAAGR,cAAc,CAACS,WAAW,CAACL,YAAY,CAAC;EAC9D,MAAMtG,MAAM,GACVA,MAA2B,IAE3B0G,aAAa,CAAC1G,MAAM,CAAC,CAACuB,IAAI,CACxB/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEhF;IAAM;GACrB,CAAC,CACI;EAEV,MAAM4G,kBAAkB,GAAG,OAAOjI,WAAW,CAACuG,IAAI,CAAC,GAAGxB,OAAO,CAACoB,UAAU,aAAa,EAAE;IACrFb,OAAO,EAAER,KAAK,CAACzD,MAAM;IACrBmE,OAAO,EAAGC,OAAO,IAAKR,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,IAAIX,GAAG,CAAC5D,MAAM,CAACoE,OAAO,CAAC;GACtF,CAAC;EACF,MAAMyC,gBAAgB,GAAG,OAAO1I,GAAG,CAACoI,UAAU,CAACK,kBAAkB,EAAE;IACjEJ,MAAM,EAAE9C,OAAO,CAAC8C,MAAM;IACtBC,YAAY,EAAE/C,OAAO,CAAC+C;GACvB,CAAC;EACF,MAAMK,iBAAiB,GAAGF,kBAAkB,CAACD,WAAW,CAACE,gBAAgB,CAAC;EAC1E,MAAM1B,UAAU,GACdnF,MAA2B,IAE3B8G,iBAAiB,CAAC9G,MAAM,CAAC,CAACuB,IAAI,CAC5B/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,aAAa,EAAE;IAClDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEhF;IAAM;GACrB,CAAC,CACI;EAEV,MAAM+G,gBAAgB,GAAG,OAAOpI,WAAW,CAACqI,OAAO,CAAC,GAAGtD,OAAO,CAACoB,UAAU,WAAW,EAAE;IACpFb,OAAO,EAAEJ,QAAQ;IACjBoD,eAAeA,CAACrB,EAAE;MAChB,OAAOA,EAAE;IACX,CAAC;IACD1B,MAAM,EAAET,KAAK;IACbyD,cAAcA,CAAC9C,OAAO;MACpB,OAAOA,OAAO,CAACN,QAAQ,CAAC;IAC1B,CAAC;IACDK,OAAO,EAAGgD,GAAG,IAAKvD,GAAG,iBAAiBA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,UAAUX,GAAG,CAACwD,EAAE,CAACtD,QAAQ,EAAEqD,GAAG,CAAC;GAC5F,CAAC;EACF,MAAME,cAAc,GAAG,OAAOlJ,GAAG,CAACoI,UAAU,CAACQ,gBAAgB,EAAE;IAC7DP,MAAM,EAAE9C,OAAO,CAAC8C,MAAM;IACtBC,YAAY,EAAE/C,OAAO,CAAC+C;GACvB,CAAC;EACF,MAAMa,eAAe,GAAGP,gBAAgB,CAACJ,WAAW,CAACU,cAAc,CAAC;EACpE,MAAMxB,QAAQ,GAAID,EAAuC,IACvD0B,eAAe,CAAC1B,EAAE,CAAC,CAACrE,IAAI,CACtB/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,WAAW,EAAE;IAChDC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,MAAM2B,cAAc,GAAG,OAAO5I,WAAW,CAACuG,IAAI,CAAC,GAAGxB,OAAO,CAACoB,UAAU,SAAS,EAAE;IAC7Eb,OAAO,EAAEJ,QAAQ;IACjBM,OAAO,EAAGgD,GAAG,IAAKvD,GAAG,eAAeA,GAAG,CAACF,OAAO,CAACa,SAAS,CAAC,UAAUX,GAAG,CAACwD,EAAE,CAACtD,QAAQ,EAAEqD,GAAG,CAAC;GAC1F,CAAC;EACF,MAAMK,YAAY,GAAG,OAAOrJ,GAAG,CAACoI,UAAU,CAACgB,cAAc,EAAE;IACzDf,MAAM,EAAE9C,OAAO,CAAC8C,MAAM;IACtBC,YAAY,EAAE/C,OAAO,CAAC+C;GACvB,CAAC;EACF,MAAMgB,aAAa,GAAGF,cAAc,CAACZ,WAAW,CAACa,YAAY,CAAC;EAC9D,MAAMzB,OAAO,GAAIH,EAAuC,IACtD6B,aAAa,CAAC7B,EAAE,CAAC,CAACrE,IAAI,CACpB/C,MAAM,CAACoG,KAAK,EACZpG,MAAM,CAACqG,QAAQ,CAAC,GAAGnB,OAAO,CAACoB,UAAU,SAAS,EAAE;IAC9CC,iBAAiB,EAAE,KAAK;IACxBC,UAAU,EAAE;MAAEY;IAAE;GACjB,CAAC,CACI;EAEV,OAAO;IAAE5F,MAAM;IAAEmF,UAAU;IAAEU,QAAQ;IAAEG,MAAM,EAAED;EAAO,CAAW;AACnE,CAAC,CAAC","ignoreList":[]}

package.json

 {
   "name": "@effect/sql",
-  "version": "0.11.1",
+  "version": "0.11.2",
   "description": "A SQL toolkit for Effect",
@@ -16,6 +16,6 @@ "license": "MIT",
   "peerDependencies": {
-    "@effect/experimental": "^0.25.1",
-    "@effect/platform": "^0.64.0",
-    "@effect/schema": "^0.72.3",
-    "effect": "^3.7.2"
+    "@effect/experimental": "^0.25.2",
+    "@effect/platform": "^0.64.1",
+    "@effect/schema": "^0.72.4",
+    "effect": "^3.7.3"
   },
@@ -22,0 +22,0 @@ "publishConfig": {

src/Migrator/FileSystem.ts

@@ -33,2 +33,3 @@ /**
                         /* @vite-ignore */
+                        /* webpackIgnore: true */
                         `${directory}/${basename}`
@@ -35,0 +36,0 @@ )

src/Model.ts

@@ -624,5 +624,11 @@ /**
     ) => Effect.Effect<S["Type"], never, S["Context"] | S["insert"]["Context"]>
+    readonly insertVoid: (
+      insert: S["insert"]["Type"]
+    ) => Effect.Effect<void, never, S["Context"] | S["insert"]["Context"]>
     readonly update: (
       update: S["update"]["Type"]
     ) => Effect.Effect<S["Type"], never, S["Context"] | S["update"]["Context"]>
+    readonly updateVoid: (
+      update: S["update"]["Type"]
+    ) => Effect.Effect<void, never, S["Context"] | S["update"]["Context"]>
     readonly findById: (
@@ -641,2 +647,3 @@ id: Schema.Schema.Type<S["fields"][Id]>
     const idSchema = Model.fields[options.idColumn] as Schema.Schema.Any
+    const idColumn = options.idColumn as string
 
@@ -646,3 +653,11 @@ const insertSchema = SqlSchema.single({
       Result: Model,
-      execute: (request) => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+      execute: (request) =>
+        sql.onDialectOrElse({
+          mysql: () =>
+            sql`insert into ${sql(options.tableName)} ${sql.insert(request)};
+select * from ${sql(options.tableName)} where ${sql(idColumn)} = LAST_INSERT_ID();`.unprepared.pipe(
+              Effect.map(([, results]) => results as any)
+            ),
+          orElse: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+        })
     })
@@ -660,2 +675,17 @@ const insert = (
 
+    const insertVoidSchema = SqlSchema.void({
+      Request: Model.insert,
+      execute: (request) => sql`insert into ${sql(options.tableName)} ${sql.insert(request)}`
+    })
+    const insertVoid = (
+      insert: S["insert"]["Type"]
+    ): Effect.Effect<void, never, S["Context"] | S["insert"]["Context"]> =>
+      insertVoidSchema(insert).pipe(
+        Effect.orDie,
+        Effect.withSpan(`${options.spanPrefix}.insertVoid`, {
+          captureStackTrace: false,
+          attributes: { insert }
+        })
+      ) as any
+
     const updateSchema = SqlSchema.single({
@@ -665,5 +695,19 @@ Request: Model.update,
       execute: (request) =>
-        sql`update ${sql(options.tableName)} set ${sql.update(request, [options.idColumn])} where ${
-          sql(options.idColumn as string)
-        } = ${sql(request[options.idColumn])} returning *`
+        sql.onDialectOrElse({
+          mysql: () =>
+            sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${
+              request[idColumn]
+            }`.raw.pipe(
+              Effect.zipRight(
+                sql`select * from ${sql(options.tableName)} where ${sql(options.idColumn as string)} = ${
+                  request[idColumn]
+                }`
+              ),
+              sql.withTransaction
+            ),
+          orElse: () =>
+            sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${
+              request[idColumn]
+            } returning *`
+        })
     })
@@ -681,6 +725,24 @@ const update = (
 
+    const updateVoidSchema = SqlSchema.void({
+      Request: Model.update,
+      execute: (request) =>
+        sql`update ${sql(options.tableName)} set ${sql.update(request, [idColumn])} where ${sql(idColumn)} = ${
+          request[idColumn]
+        }`
+    })
+    const updateVoid = (
+      update: S["update"]["Type"]
+    ): Effect.Effect<void, never, S["Context"] | S["update"]["Context"]> =>
+      updateVoidSchema(update).pipe(
+        Effect.orDie,
+        Effect.withSpan(`${options.spanPrefix}.updateVoid`, {
+          captureStackTrace: false,
+          attributes: { update }
+        })
+      ) as any
+
     const findByIdSchema = SqlSchema.findOne({
       Request: idSchema,
       Result: Model,
-      execute: (id) => sql`select * from ${sql(options.tableName)} where ${sql(options.idColumn as string)} = ${id}`
+      execute: (id) => sql`select * from ${sql(options.tableName)} where ${sql(idColumn)} = ${id}`
     })
@@ -700,3 +762,3 @@ const findById = (
       Request: idSchema,
-      execute: (id) => sql`delete from ${sql(options.tableName)} where ${sql(options.idColumn as string)} = ${id}`
+      execute: (id) => sql`delete from ${sql(options.tableName)} where ${sql(idColumn)} = ${id}`
     })
@@ -714,3 +776,3 @@ const delete_ = (
 
-    return { insert, update, findById, delete: delete_ } as const
+    return { insert, insertVoid, update, updateVoid, findById, delete: delete_ } as const
   })
@@ -739,2 +801,3 @@
     readonly insert: (insert: S["insert"]["Type"]) => Effect.Effect<S["Type"]>
+    readonly insertVoid: (insert: S["insert"]["Type"]) => Effect.Effect<void>
     readonly findById: (id: Schema.Schema.Type<S["fields"][Id]>) => Effect.Effect<Option.Option<S["Type"]>>
@@ -749,2 +812,3 @@ readonly delete: (id: Schema.Schema.Type<S["fields"][Id]>) => Effect.Effect<void>
     const idSchema = Model.fields[options.idColumn] as Schema.Schema.Any
+    const idColumn = options.idColumn as string
 
@@ -754,3 +818,12 @@ const insertResolver = yield* SqlResolver.ordered(`${options.spanPrefix}/insert`, {
       Result: Model,
-      execute: (request) => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+      execute: (request) =>
+        sql.onDialectOrElse({
+          mysql: () =>
+            Effect.forEach(request, (request) =>
+              sql`insert into ${sql(options.tableName)} ${sql.insert(request)};
+select * from ${sql(options.tableName)} where ${sql(idColumn)} = LAST_INSERT_ID();`.unprepared.pipe(
+                Effect.map(([, results]) => results[0] as any)
+              ), { concurrency: 10 }),
+          orElse: () => sql`insert into ${sql(options.tableName)} ${sql.insert(request).returning("*")}`
+        })
     })
@@ -773,2 +846,22 @@ const insertLoader = yield* RRX.dataLoader(insertResolver, {
 
+    const insertVoidResolver = yield* SqlResolver.void(`${options.spanPrefix}/insertVoid`, {
+      Request: Model.insert,
+      execute: (request) => sql`insert into ${sql(options.tableName)} ${sql.insert(request)}`
+    })
+    const insertVoidLoader = yield* RRX.dataLoader(insertVoidResolver, {
+      window: options.window,
+      maxBatchSize: options.maxBatchSize!
+    })
+    const insertVoidExecute = insertVoidResolver.makeExecute(insertVoidLoader)
+    const insertVoid = (
+      insert: S["insert"]["Type"]
+    ): Effect.Effect<void, never, S["Context"] | S["insert"]["Context"]> =>
+      insertVoidExecute(insert).pipe(
+        Effect.orDie,
+        Effect.withSpan(`${options.spanPrefix}.insertVoid`, {
+          captureStackTrace: false,
+          attributes: { insert }
+        })
+      ) as any
+
     const findByIdResolver = yield* SqlResolver.grouped(`${options.spanPrefix}/findById`, {
@@ -781,5 +874,5 @@ Request: idSchema,
       ResultGroupKey(request) {
-        return request[options.idColumn]
+        return request[idColumn]
       },
-      execute: (ids) => sql`select * from ${sql(options.tableName)} where ${sql.in(options.idColumn as string, ids)}`
+      execute: (ids) => sql`select * from ${sql(options.tableName)} where ${sql.in(idColumn, ids)}`
     })
@@ -802,3 +895,3 @@ const findByIdLoader = yield* RRX.dataLoader(findByIdResolver, {
       Request: idSchema,
-      execute: (ids) => sql`delete from ${sql(options.tableName)} where ${sql.in(options.idColumn as string, ids)}`
+      execute: (ids) => sql`delete from ${sql(options.tableName)} where ${sql.in(idColumn, ids)}`
     })
@@ -819,3 +912,3 @@ const deleteLoader = yield* RRX.dataLoader(deleteResolver, {
 
-    return { insert, findById, delete: delete_ } as const
+    return { insert, insertVoid, findById, delete: delete_ } as const
   })

No alert changes

Improved metrics

Total package byte prevSize

522646

3.12%

Lines of code

8601

2.43%

No dependency changes