refactor(share): remove session share async facade exports
This commit is contained in:
parent
f954854232
commit
fe3303163c
3 changed files with 18 additions and 14 deletions
|
|
@ -564,7 +564,7 @@ export const GithubRunCommand = cmd({
|
||||||
shareId = await (async () => {
|
shareId = await (async () => {
|
||||||
if (share === false) return
|
if (share === false) return
|
||||||
if (!share && repoData.data.private) return
|
if (!share && repoData.data.private) return
|
||||||
await SessionShare.share(session.id)
|
await AppRuntime.runPromise(SessionShare.Service.use((svc) => svc.share(session.id)))
|
||||||
return session.id.slice(-8)
|
return session.id.slice(-8)
|
||||||
})()
|
})()
|
||||||
console.log("opencode session", session.id)
|
console.log("opencode session", session.id)
|
||||||
|
|
|
||||||
|
|
@ -212,7 +212,7 @@ export const SessionRoutes = lazy(() =>
|
||||||
validator("json", Session.create.schema),
|
validator("json", Session.create.schema),
|
||||||
async (c) => {
|
async (c) => {
|
||||||
const body = c.req.valid("json") ?? {}
|
const body = c.req.valid("json") ?? {}
|
||||||
const session = await SessionShare.create(body)
|
const session = await AppRuntime.runPromise(SessionShare.Service.use((svc) => svc.create(body)))
|
||||||
return c.json(session)
|
return c.json(session)
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
@ -437,8 +437,14 @@ export const SessionRoutes = lazy(() =>
|
||||||
),
|
),
|
||||||
async (c) => {
|
async (c) => {
|
||||||
const sessionID = c.req.valid("param").sessionID
|
const sessionID = c.req.valid("param").sessionID
|
||||||
await SessionShare.share(sessionID)
|
const session = await AppRuntime.runPromise(
|
||||||
const session = await Session.get(sessionID)
|
Effect.gen(function* () {
|
||||||
|
const share = yield* SessionShare.Service
|
||||||
|
const session = yield* Session.Service
|
||||||
|
yield* share.share(sessionID)
|
||||||
|
return yield* session.get(sessionID)
|
||||||
|
}),
|
||||||
|
)
|
||||||
return c.json(session)
|
return c.json(session)
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
@ -511,8 +517,14 @@ export const SessionRoutes = lazy(() =>
|
||||||
),
|
),
|
||||||
async (c) => {
|
async (c) => {
|
||||||
const sessionID = c.req.valid("param").sessionID
|
const sessionID = c.req.valid("param").sessionID
|
||||||
await SessionShare.unshare(sessionID)
|
const session = await AppRuntime.runPromise(
|
||||||
const session = await Session.get(sessionID)
|
Effect.gen(function* () {
|
||||||
|
const share = yield* SessionShare.Service
|
||||||
|
const session = yield* Session.Service
|
||||||
|
yield* share.unshare(sessionID)
|
||||||
|
return yield* session.get(sessionID)
|
||||||
|
}),
|
||||||
|
)
|
||||||
return c.json(session)
|
return c.json(session)
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -1,8 +1,6 @@
|
||||||
import { makeRuntime } from "@/effect/run-service"
|
|
||||||
import { Session } from "@/session"
|
import { Session } from "@/session"
|
||||||
import { SessionID } from "@/session/schema"
|
import { SessionID } from "@/session/schema"
|
||||||
import { SyncEvent } from "@/sync"
|
import { SyncEvent } from "@/sync"
|
||||||
import { fn } from "@/util/fn"
|
|
||||||
import { Effect, Layer, Scope, Context } from "effect"
|
import { Effect, Layer, Scope, Context } from "effect"
|
||||||
import { Config } from "../config/config"
|
import { Config } from "../config/config"
|
||||||
import { Flag } from "../flag/flag"
|
import { Flag } from "../flag/flag"
|
||||||
|
|
@ -58,10 +56,4 @@ export namespace SessionShare {
|
||||||
Layer.provide(Session.defaultLayer),
|
Layer.provide(Session.defaultLayer),
|
||||||
Layer.provide(Config.defaultLayer),
|
Layer.provide(Config.defaultLayer),
|
||||||
)
|
)
|
||||||
|
|
||||||
const { runPromise } = makeRuntime(Service, defaultLayer)
|
|
||||||
|
|
||||||
export const create = fn(Session.create.schema, (input) => runPromise((svc) => svc.create(input)))
|
|
||||||
export const share = fn(SessionID.zod, (sessionID) => runPromise((svc) => svc.share(sessionID)))
|
|
||||||
export const unshare = fn(SessionID.zod, (sessionID) => runPromise((svc) => svc.unshare(sessionID)))
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue