main.go

package main

import (
	"encoding/json"
	"fmt"
)

func fetchAPI(done <-chan struct{}) <-chan string {
	out := make(chan string)
	go func() {
		defer close(out)
		data := []string{
			`{"id": 1, "name": "Alice", "status": "active"}`,
			`{"id": 2, "name": "Bob", "status": "inactive"}`,
			`{"id": 3, "name": "Charlie", "status": "active"}`,
		}
		for _, v := range data {
			select {
			case out <- v:
			case <-done:
				return
			}
		}
	}()
	return out
}

func parseJson(done <-chan struct{}, in <-chan string) <-chan map[string]interface{} {
	out := make(chan map[string]interface{})
	go func() {
		defer close(out)
		for raw := range in {
			var result map[string]interface{}
			if err := json.Unmarshal([]byte(raw), &result); err != nil {
				fmt.Println("Error parsing JSON:", err)
				continue
			}
			select {
			case out <- result:
			case <-done:
				return
			}
		}
	}()
	return out
}

func filterData(done <-chan struct{}, in <-chan map[string]interface{}) <-chan map[string]interface{} {
	out := make(chan map[string]interface{})
	go func() {
		defer close(out)
		for item := range in {
			if status, ok := item["status"].(string); ok && status == "active" {
				select {
				case out <- item:
				case <-done:
					return
				}
			}
		}
	}()
	return out
}

func saveToDB(done <-chan struct{}, in <-chan map[string]interface{}) {
	for item := range in {
		fmt.Println("Saving to DB:", item)
	}
}


func main() {
	done := make(chan struct{})
	defer close(done)

	fetchedData := fetchAPI(done)
	parseData := parseJson(done, fetchedData)
	filteredData := filterData(done, parseData)
	saveToDB(done, filteredData)
}