Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add initial transactor rpc #7490

Merged
merged 24 commits into from
Dec 20, 2024
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
make worker transactor running (#7455)
Signed-off-by: Nikolay Chunosov <Chunosov.N@gmail.com>
  • Loading branch information
Chunosov committed Dec 19, 2024
commit b3a2848dd5553d04bc5f8edfc7009ae9f6af0817
6 changes: 5 additions & 1 deletion workers/transactor/src/pipeline.ts
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ import {
DomainTxMiddleware,
LiveQueryMiddleware,
LookupMiddleware,
LowLevelMiddleware,
MarkDerivedEntryMiddleware,
ModelMiddleware,
ModifiedMiddleware,
Expand All @@ -49,6 +50,7 @@ import {
type MiddlewareCreator,
type PipelineContext
} from '@hcengineering/server-core'
import { createDummyStorageAdapter } from '@hcengineering/storage'

export async function createaPipeline (
ctx: MeasureContext,
Expand Down Expand Up @@ -123,6 +125,7 @@ export async function createaPipeline (
TriggersMiddleware.create,
// TODO: Add Full text state update middleware
// FullTextMiddleware.create(conf, false), // TODO: Fix Fulltext search
LowLevelMiddleware.create,
QueryJoinMiddleware.create,
LiveQueryMiddleware.create,
DomainFindMiddleware.create,
Expand All @@ -139,7 +142,8 @@ export async function createaPipeline (
workspace,
branding,
modelDb,
hierarchy
hierarchy,
storageAdapter: createDummyStorageAdapter()
}
return await createPipeline(ctx, middlewares, context)
}
3 changes: 1 addition & 2 deletions workers/transactor/src/transactor.ts
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import {
generateId,
MeasureMetricsContext,
type MeasureContext,
type Tx,
type WorkspaceIdWithUrl
} from '@hcengineering/core'
import { setMetadata } from '@hcengineering/platform'
Expand All @@ -20,7 +19,7 @@ import {
type PipelineFactory,
type SessionManager
} from '@hcengineering/server-core'
// import { registerStringLoaders } from '@hcengineering/server-pipeline'
import { registerServerPlugins } from '@hcengineering/server-pipeline'
import serverPlugin, { decodeToken, type Token } from '@hcengineering/server-token'
import { DurableObject } from 'cloudflare:workers'

Expand Down