package main

import (
	"context"
	"errors"
)

type PersistenceToNormalized struct {
	pipeline Pipeline
}

func NewPersistenceToNormalizedPipeline(ctx context.Context, cfg Config) (Pipeline, error) {
	reader, err := NewQueue(ctx, "new_message", cfg.driver)
	if err != nil {
		return Pipeline{}, err
	}
	writer, err := NewQueue(ctx, "new_persistence", cfg.driver)
	if err != nil {
		return Pipeline{}, err
	}
	return Pipeline{
		writer:  writer,
		reader:  reader,
		process: newPersistenceToNormalizedProcess(cfg.driver),
	}, nil
}

func newPersistenceToNormalizedProcess(driver Driver) processFunc {
	return func(ctx context.Context, msg []byte) ([]byte, error) {
		return nil, errors.New("not impl")
	}
}