Mirroristas/pockethost
2
0
Fork 0
mirror of https://github.com/pockethost/pockethost.git synced 2025-05-19 13:26:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: track uid in invocations

Browse Source
This commit is contained in:
Ben Allfree 2023-09-20 06:54:53 -07:00
parent f0bc038397
commit 791876d0ed
5 changed files with 102 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
packages/common/src/schema/Invocation.ts
View File

@ -4,6 +4,7 @@ export const INVOCATION_COLLECTION = 'invocations'
export type InvocationPid = string export type InvocationPid = string
export type InvocationFields = BaseFields & { export type InvocationFields = BaseFields & {
uid: RecordId
instanceId: RecordId instanceId: RecordId
startedAt: IsoDate startedAt: IsoDate
endedAt: IsoDate endedAt: IsoDate

54
packages/daemon/migrations/1695129360_updated_invocations.js Normal file
View File

@ -0,0 +1,54 @@
/// <reference path="../pb_data/types.d.ts" />
migrate((db) => {
const dao = new Dao(db)
const collection = dao.findCollectionByNameOrId("aiw8te7y7atklwn")
collection.indexes = [
"CREATE INDEX `idx_CTV52b6` ON `invocations` (`created`)",
"CREATE INDEX `idx_6rNZeTK` ON `invocations` (`instanceId`)",
"CREATE INDEX `idx_LTmqfbC` ON `invocations` (`totalSeconds`)",
"CREATE INDEX `idx_7YR9a3g` ON `invocations` (\n `instanceId`,\n `created`\n)",
"CREATE INDEX `idx_ntC1d1L` ON `invocations` (\n `totalSeconds`,\n `created`\n)",
"CREATE INDEX `idx_vViR75E` ON `invocations` (\n `created`,\n `totalSeconds`\n)",
"CREATE INDEX `idx_q9LanEj` ON `invocations` (\n `created`,\n `instanceId`\n)",
"CREATE INDEX `idx_ueUQe1N` ON `invocations` (`uid`)"
]
// add
collection.schema.addField(new SchemaField({
"system": false,
"id": "kmyokg1d",
"name": "uid",
"type": "relation",
"required": false,
"presentable": false,
"unique": false,
"options": {
"collectionId": "systemprofiles0",
"cascadeDelete": false,
"minSelect": null,
"maxSelect": 1,
"displayFields": null
}
}))
return dao.saveCollection(collection)
}, (db) => {
const dao = new Dao(db)
const collection = dao.findCollectionByNameOrId("aiw8te7y7atklwn")
collection.indexes = [
"CREATE INDEX `idx_CTV52b6` ON `invocations` (`created`)",
"CREATE INDEX `idx_6rNZeTK` ON `invocations` (`instanceId`)",
"CREATE INDEX `idx_LTmqfbC` ON `invocations` (`totalSeconds`)",
"CREATE INDEX `idx_7YR9a3g` ON `invocations` (\n `instanceId`,\n `created`\n)",
"CREATE INDEX `idx_ntC1d1L` ON `invocations` (\n `totalSeconds`,\n `created`\n)",
"CREATE INDEX `idx_vViR75E` ON `invocations` (\n `created`,\n `totalSeconds`\n)",
"CREATE INDEX `idx_q9LanEj` ON `invocations` (\n `created`,\n `instanceId`\n)"
]
// remove
collection.schema.removeField("kmyokg1d")
return dao.saveCollection(collection)
})

10
packages/daemon/migrations/1695129536_update_invocation_uids.js Normal file
View File

@ -0,0 +1,10 @@
/// <reference path="../pb_data/types.d.ts" />
migrate(
(db) => {
db.newQuery(
'UPDATE invocations SET uid = (select uid from instances where instances.id = invocations.instanceId)',
).execute()
},
(db) => {},
)

36
packages/daemon/migrations/1695130842_updated_invocations.js Normal file
View File

@ -0,0 +1,36 @@
/// <reference path="../pb_data/types.d.ts" />
migrate((db) => {
const dao = new Dao(db)
const collection = dao.findCollectionByNameOrId("aiw8te7y7atklwn")
collection.indexes = [
"CREATE INDEX `idx_CTV52b6` ON `invocations` (`created`)",
"CREATE INDEX `idx_6rNZeTK` ON `invocations` (`instanceId`)",
"CREATE INDEX `idx_LTmqfbC` ON `invocations` (`totalSeconds`)",
"CREATE INDEX `idx_7YR9a3g` ON `invocations` (\n `instanceId`,\n `created`\n)",
"CREATE INDEX `idx_ntC1d1L` ON `invocations` (\n `totalSeconds`,\n `created`\n)",
"CREATE INDEX `idx_vViR75E` ON `invocations` (\n `created`,\n `totalSeconds`\n)",
"CREATE INDEX `idx_q9LanEj` ON `invocations` (\n `created`,\n `instanceId`\n)",
"CREATE INDEX `idx_ueUQe1N` ON `invocations` (`uid`)",
"CREATE INDEX `idx_gh6iEUG` ON `invocations` (\n `instanceId`,\n `startedAt`\n)",
"CREATE INDEX `idx_CUsNbfu` ON `invocations` (\n `uid`,\n `startedAt`\n)"
]
return dao.saveCollection(collection)
}, (db) => {
const dao = new Dao(db)
const collection = dao.findCollectionByNameOrId("aiw8te7y7atklwn")
collection.indexes = [
"CREATE INDEX `idx_CTV52b6` ON `invocations` (`created`)",
"CREATE INDEX `idx_6rNZeTK` ON `invocations` (`instanceId`)",
"CREATE INDEX `idx_LTmqfbC` ON `invocations` (`totalSeconds`)",
"CREATE INDEX `idx_7YR9a3g` ON `invocations` (\n `instanceId`,\n `created`\n)",
"CREATE INDEX `idx_ntC1d1L` ON `invocations` (\n `totalSeconds`,\n `created`\n)",
"CREATE INDEX `idx_vViR75E` ON `invocations` (\n `created`,\n `totalSeconds`\n)",
"CREATE INDEX `idx_q9LanEj` ON `invocations` (\n `created`,\n `instanceId`\n)",
"CREATE INDEX `idx_ueUQe1N` ON `invocations` (`uid`)"
]
return dao.saveCollection(collection)
})

1
packages/daemon/src/services/clientService/InvocationMixin.ts
View File

@ -22,6 +22,7 @@ export const createInvocationMixin = (
logger, logger,
async (instance: InstanceFields, pid: InvocationPid) => { async (instance: InstanceFields, pid: InvocationPid) => {
const init: Partial<InvocationFields> = { const init: Partial<InvocationFields> = {
uid: instance.uid,
startedAt: pocketNow(), startedAt: pocketNow(),
pid, pid,
instanceId: instance.id, instanceId: instance.id,