(e: PM)
| 78 | if (namespace !== "primary" && !config.allowNamespace!(namespace)) { |
| 79 | throw new Error(`Namespace ${namespace} not allowed!`) |
| 80 | } |
| 81 | return namespace |
| 82 | })) |
| 83 | |
| 84 | const ensureTable = sql |
| 85 | .unsafe( |
| 86 | `CREATE TABLE IF NOT EXISTS "${tableName}" (id TEXT NOT NULL, _namespace TEXT NOT NULL DEFAULT 'primary', _etag TEXT, data JSONB NOT NULL, PRIMARY KEY (id, _namespace))` |
| 87 | ) |
| 88 | .pipe( |
| 89 | Effect.andThen( |