def source.canonical

mylsm-lsm-store@0.6.0.1 · src/transfer/MigrateIo.bend:924

import Base
import mylsm-lsm-store@0.6.0.1/src/Fs.bend as Fs

924def source.canonical(
925  result: Result<&1, &1, U32 & String, String>
926) -> IO(Result<&1, &1, Error, SourceSnapshot>):
927  match result:
928    case Fail{(code, message)}:
929      IO.pure(Result<&1, &1, Error, SourceSnapshot>, Fail{HostError{code, message}})
930    case Done{+path}:
931      do IO<Result<&1, &1, Error, SourceSnapshot>>:
932        present : Result<&1, &1, U32 & String, Bool> <- Fs.exists(path ++ "/LOCK")
933        source.lock.present(path, present)