package commands

import (
	"net"
	"redisClone/pkg/core"
	"redisClone/pkg/pubsub"
)

func Unsubscribe(hub *pubsub.Hub, conn net.Conn, args []string) interface{}{
	channels := args[1:]
	results := hub.Unsubscribe(conn, channels)

	for channel, remainingCount := range results {
		resp := core.SerializeRESP([]interface{}{"unsubscribe", channel, remainingCount})
		conn.Write(resp)
	}

	return nil
}