routier-collection / plugins/replication/src / HttpDbPlugin
Class: HttpDbPlugin
Defined in: plugins/replication/src/HttpDbPlugin.ts:117
Implements
IDbPlugin
Constructors
Constructor
new HttpDbPlugin(
options):HttpDbPlugin
Defined in: plugins/replication/src/HttpDbPlugin.ts:140
Parameters
options
Returns
HttpDbPlugin
Properties
databaseName
readonlydatabaseName:string
Defined in: plugins/replication/src/HttpDbPlugin.ts:138
See IDbPlugin.databaseName and HttpPluginOptions.databaseName.
Implementation of
IDbPlugin.databaseName
Methods
collectionUrl()
collectionUrl(
collectionName):string
Defined in: plugins/replication/src/HttpDbPlugin.ts:158
Exposed for composing plugins (e.g. HttpSwrDbPlugin) that need to build request URLs.
Parameters
collectionName
string
Returns
string
requestHeaders()
requestHeaders():
Promise<Record<string,string>>
Defined in: plugins/replication/src/HttpDbPlugin.ts:163
Exposed for composing plugins that need to add auth or other headers to fetch/HTTP calls.
Returns
Promise<Record<string, string>>
notifyAuthError()
notifyAuthError(
event):Promise<boolean>
Defined in: plugins/replication/src/HttpDbPlugin.ts:172
Notifies onAuthError and reports whether the handler claims re-auth succeeded (a truthy return/resolution). Handler exceptions are logged, never propagated.
Parameters
event
Returns
Promise<boolean>
query()
query<
TRoot,TShape>(event,done):void
Defined in: plugins/replication/src/HttpDbPlugin.ts:248
Executes a query operation on the database.
Type Parameters
TRoot
TRoot extends object
TShape
TShape
Parameters
event
DbPluginQueryEvent<TRoot, TShape>
The query event containing schema, parent, and query operation.
done
PluginEventCallbackResult<ITranslatedValue<TShape>>
Callback with the result or error.
Returns
void
Implementation of
IDbPlugin.query
bulkPersist()
bulkPersist(
event,done):void
Defined in: plugins/replication/src/HttpDbPlugin.ts:350
Executes bulk operations (add, update, remove) on the database.
Parameters
event
DbPluginBulkPersistEvent
The bulk operations event containing schema, parent, and changes.
done
PluginEventCallbackPartialResult<BulkPersistResult>
Callback with the result or error.
Returns
void
Implementation of
IDbPlugin.bulkPersist
postJson()
postJson(
url,body,_collectionName):Promise<unknown>
Defined in: plugins/replication/src/HttpDbPlugin.ts:455
Enqueues a body for batching by URL, then POSTs the merged body through the pacer.
Exposed because a composing plugin has no business opening its own sockets: this used to be duplicated inside HttpSwrDbPlugin, with a second RequestTracker and no pacing at all, so every write bypassed everything this class guarantees.
Parameters
url
string
body
string
_collectionName
string
Returns
Promise<unknown>
pendingRequestCount()
pendingRequestCount():
number
Defined in: plugins/replication/src/HttpDbPlugin.ts:475
Calls accepted and not finished, including writes waiting in the batch window.
Returns
number
destroy()
destroy(
_event,done):void
Defined in: plugins/replication/src/HttpDbPlugin.ts:498
Destroys or cleans up the plugin, closing connections or freeing resources.
Parameters
_event
DbPluginEvent
done
PluginEventCallbackResult<never>
Callback with an optional error.
Returns
void
Implementation of
IDbPlugin.destroy