aboutsummaryrefslogblamecommitdiff
path: root/main.go
blob: 4a4f242dd58409326580035b17990b72c1d16839 (plain) (tree)
1
2
3
4
5
6
7
8

            
        
                 
              
             

                                                      




                                       
                                                                                                      

                    
                                        
                       
                                                                                     

         
                                                                  
                       
                                                                

                              
                                                                                 



                                              
                                                                                  
                 
                                                                                       

                           


                                                                               





                                                                                                                                                  
                                
                                                                                                                    


                         
 
package main

import (
	"context"
	"flag"
	"net"

	"go.lindenii.runxiyu.org/lindenii-common/clog"
)

const VERSION = "lindenii-maild v0.0.0"

func main() {
	config_path := flag.String("config", "/etc/lindenii/maild.scfg", "path to configuration file")
	flag.Parse()

	err := load_config(*config_path)
	if err != nil {
		clog.Fatal(1, "Error while loading configuration file: "+err.Error())
	}

	listener, err := net.Listen(config.MX.Net, config.MX.Addr)
	if err != nil {
		clog.Fatal(1, "MX: Cannot listen: "+err.Error())
	}
	defer listener.Close()
	clog.Info("MX: Listening via " + config.MX.Net + " on " + config.MX.Addr)

	for {
		conn, err := listener.Accept()
		if err != nil {
			clog.Error("MX: Cannot accept connection: " + err.Error())
		}
		clog.Info("MX: Accepted connection from " + conn.RemoteAddr().String())

		go func() {
			ctx, cancel := context.WithCancel(context.Background())
			defer cancel()
			err := handle_mx_recv_conn(ctx, conn)
			if err != nil {
				if err == err_connection_handler_eof {
					clog.Info("MX: Connection for " + conn.RemoteAddr().String() + " closed with EOF")
				} else {
					clog.Error("MX: Connection handler for " + conn.RemoteAddr().String() + " returned error: " + err.Error())
				}
			} else {
				clog.Info("MX: Connection for " + conn.RemoteAddr().String() + " closed gracefully")
			}
		}()
	}
}