import org.slf4j.LoggerFactory


object LoggerCodec : Codec<Logger> {

    override suspend fun WriteContext.encode(value: Logger) {
        writeString(value.name)
    }

    override suspend fun ReadContext.decode(): Logger? =
        LoggerFactory.getLogger(readString())

import java.nio.charset.Charset


object CharsetCodec : Codec<Charset> {

    override suspend fun WriteContext.encode(value: Charset) {
        writeString(value.name())
    }

    override suspend fun ReadContext.decode(): Charset =
        Charset.forName(readString())

import java.net.URL


object UrlCodec : Codec<URL> {

    override suspend fun WriteContext.encode(value: URL) {
        writeString(value.toExternalForm())
    }

    override suspend fun ReadContext.decode(): URL =
        URL(readString())

) : Codec<ActionNode> {
    override suspend fun WriteContext.encode(value: ActionNode) {
        withCodec(userTypesCodec) {
            write(value.action)
        }
    }

    override suspend fun ReadContext.decode(): ActionNode {
        val action = withCodec(userTypesCodec) { readNonNull<WorkNodeAction>() }
        return ActionNode(action)
    }

object WorkNodeActionCodec : Codec<WorkNodeAction> {
    override suspend fun WriteContext.encode(value: WorkNodeAction) {
        logNotImplemented(value.javaClass)
    }

    override suspend fun ReadContext.decode(): WorkNodeAction {
        // TODO - should discard from graph instead
        return object : WorkNodeAction {
            override fun run(context: NodeExecutionContext) {
                // Ignore
            }

object ImmutableSetCodec : Codec<ImmutableSet<Any>> {

    override suspend fun WriteContext.encode(value: ImmutableSet<Any>) {
        writeCollection(value)
    }

    override suspend fun ReadContext.decode(): ImmutableSet<Any>? {
        val size = readSmallInt()
        val builder = ImmutableSet.builderWithExpectedSize<Any>(size)
        for (i in 0 until size) {
            val value = read()!!
            builder.add(value)

class TransformChainCodec : Codec<TransformChain> {
    override suspend fun WriteContext.encode(value: TransformChain) {
        write(value.init)
        write(value.last)
    }

    override suspend fun ReadContext.decode(): TransformChain {
        val init = read() as TransformChain?
        val last = readNonNull<TransformStep>()
        return TransformChain(init, last)
    }

object RegexpPatternCodec : Codec<Pattern> {
    override suspend fun WriteContext.encode(value: Pattern) {
        writeString(value.pattern())
        writeInt(value.flags())
    }

    override suspend fun ReadContext.decode(): Pattern? {
        return Pattern.compile(readString(), readInt())
    }

) : Codec<ConfigurableFileTree> {
    override suspend fun WriteContext.encode(value: ConfigurableFileTree) {
        writeFile(value.dir)
        write(value.patterns)
    }

    override suspend fun ReadContext.decode(): ConfigurableFileTree {
        val dir = readFile()
        val patterns = read() as PatternSet
        val tree = fileCollectionFactory.fileTree()
        tree.setDir(dir)

    override suspend fun WriteContext.encode(value: DefaultContextAwareTaskLogger) {
        encodePreservingIdentityOf(value) {
            write(it.messageRewriter)
        }
    }

    override suspend fun ReadContext.decode(): DefaultContextAwareTaskLogger =
        decodePreservingIdentity { id ->
            DefaultContextAwareTaskLogger(Logging.getLogger(Task::class.java)).also { logger ->
                read()?.let { rewriter ->