mail.go

var emailChannel chan *viewmodels.EmailMessage
var emailChannelClosed bool

func SendMessage(message *viewmodels.EmailMessage) {
	emailChannel <- message
}

func Open() {
	emailChannel = make(chan *viewmodels.EmailMessage)

  // JUMLAH THREAD WORKER PENGIRIMAN EMAIL
	worker := runtime.NumCPU()
	if worker < 1 {
		worker = 1
	}
	
	emailChannelClosed = false

  // JALANKAN THREAD WORKER
	for i := 0; i < worker; i++ {
		go sendMessageInBackground()
	}
}

// WORKER PENGIRIM EMAIL
func sendMessageInBackground() {

	defer func() {
		if !emailChannelClosed {
			if err := recover(); err != nil {
				log.Println("send email panic occurred:", err)
			}
		}
	}()
  
  	// BUAT KONEKSI EMAIL
  
  	// LOGIKA INFINITE LOOP CONSUME DARI emailChannel
  
  	for {
		select {
		case vMessage, ok := <-emailChannel:
			if !ok {
				return
			}
			if vMessage == nil {
				continue
			}
			
			// CEK KONEKSI EMAIL
      
      			// LOGIKA KIRIM EMAIL TARUH DISINI
      		}
    	}
}