chore: generate
This commit is contained in:
@@ -48,7 +48,9 @@ export namespace InstanceState {
|
|||||||
}),
|
}),
|
||||||
})
|
})
|
||||||
|
|
||||||
const off = registerDisposer((directory) => Effect.runPromise(ScopedCache.invalidate(cache, directory).pipe(Effect.provide(EffectLogger.layer))))
|
const off = registerDisposer((directory) =>
|
||||||
|
Effect.runPromise(ScopedCache.invalidate(cache, directory).pipe(Effect.provide(EffectLogger.layer))),
|
||||||
|
)
|
||||||
yield* Effect.addFinalizer(() => Effect.sync(off))
|
yield* Effect.addFinalizer(() => Effect.sync(off))
|
||||||
|
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -475,7 +475,9 @@ export namespace MCP {
|
|||||||
if (s.clients[name] !== client || s.status[name]?.status !== "connected") return
|
if (s.clients[name] !== client || s.status[name]?.status !== "connected") return
|
||||||
|
|
||||||
s.defs[name] = listed
|
s.defs[name] = listed
|
||||||
await Effect.runPromise(bus.publish(ToolsChanged, { server: name }).pipe(Effect.ignore, Effect.provide(EffectLogger.layer)))
|
await Effect.runPromise(
|
||||||
|
bus.publish(ToolsChanged, { server: name }).pipe(Effect.ignore, Effect.provide(EffectLogger.layer)),
|
||||||
|
)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -84,7 +84,11 @@ export namespace Plugin {
|
|||||||
}
|
}
|
||||||
|
|
||||||
function publishPluginError(bus: Bus.Interface, message: string) {
|
function publishPluginError(bus: Bus.Interface, message: string) {
|
||||||
Effect.runFork(bus.publish(Session.Event.Error, { error: new NamedError.Unknown({ message }).toObject() }).pipe(Effect.provide(EffectLogger.layer)))
|
Effect.runFork(
|
||||||
|
bus
|
||||||
|
.publish(Session.Event.Error, { error: new NamedError.Unknown({ message }).toObject() })
|
||||||
|
.pipe(Effect.provide(EffectLogger.layer)),
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
async function applyPlugin(load: PluginLoader.Loaded, input: PluginInput, hooks: Hooks[]) {
|
async function applyPlugin(load: PluginLoader.Loaded, input: PluginInput, hooks: Hooks[]) {
|
||||||
|
|||||||
@@ -1216,7 +1216,8 @@ export namespace Provider {
|
|||||||
|
|
||||||
const options = yield* Effect.promise(() =>
|
const options = yield* Effect.promise(() =>
|
||||||
plugin.auth!.loader!(
|
plugin.auth!.loader!(
|
||||||
() => Effect.runPromise(auth.get(providerID).pipe(Effect.orDie, Effect.provide(EffectLogger.layer))) as any,
|
() =>
|
||||||
|
Effect.runPromise(auth.get(providerID).pipe(Effect.orDie, Effect.provide(EffectLogger.layer))) as any,
|
||||||
database[plugin.auth!.provider],
|
database[plugin.auth!.provider],
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user