.gitignore

@@ -28,7 +28,6 @@ Checkin.code-workspace
 _obj
 _test
 .vscode/
-ChipDNAClient/
 
 # Architecture specific extensions/prefixes
 *.[568vq]

dispenser/dispenser.go

@@ -251,8 +251,6 @@ func CardToEncoderPosition(port *serial.Port) (string, error) {
 		return "", fmt.Errorf("error sending ENQ to prompt device: %v", err)
 	}
 
-	time.Sleep(delay)
-
 	//Check card position status
 	status, err := CheckDispenserStatus(port)
 	if err != nil {
@@ -283,8 +281,6 @@ func CardOutOfMouth(port *serial.Port) (string, error) {
 		return "", fmt.Errorf("error sending ENQ to prompt device: %v", err)
 	}
 
-	time.Sleep(delay)
-
 	//Check card position status
 	status, err := CheckDispenserStatus(port)
 	if err != nil {

lockserver/assalockserver.go

@@ -19,15 +19,8 @@ func (lock *AssaLockServer) BuildCommand(doorReq DoorCardRequest, checkIn, check
 }
 
 // Checks heart beat of the Assa Abloy lock server and perform key encoding
-func (lock *AssaLockServer) LockSequence() error {
+func (lock *AssaLockServer) LockSequence(conn net.Conn) error {
 	const funcName = "AssaLockServer.LockSequence"
-
-	conn, err := InitializeServerConnection(LockServerURL)
-	if err != nil {
-		return err
-	}
-	defer conn.Close()
-
 	resp, err := sendHeartbeatToServer(conn)
 	if err != nil {
 		return fmt.Errorf("[%s] heartbeat failed: %v", funcName, err)

lockserver/lockservercommon.go

@@ -35,7 +35,7 @@ var (
 type (
 	LockServer interface {
 		BuildCommand(doorReq DoorCardRequest, checkIn, checkOut time.Time) error
-		LockSequence() error
+		LockSequence(conn net.Conn) error
 	}
 
 	AssaLockServer struct {

lockserver/omnilockserver.go

@@ -53,15 +53,8 @@ func (lock *OmniLockServer) BuildCommand(doorReq DoorCardRequest, checkIn, check
 }
 
 // Starts link to the Omnitec lock server and perform key encoding
-func (lock *OmniLockServer) LockSequence() error {
+func (lock *OmniLockServer) LockSequence(conn net.Conn) error {
 	const funcName = "OmniLockServer.LockSequence"
-
-	conn, err := InitializeServerConnection(LockServerURL)
-	if err != nil {
-		return err
-	}
-	defer conn.Close()
-
 	// Start the link with the lock server
 	regs, err := lock.linkStart(conn)
 	if err != nil {

lockserver/saltolockserver.go

@@ -139,21 +139,14 @@ func (lock *SaltoLockServer) waitForAck(conn net.Conn, reader *bufio.Reader, tim
 }
 
 // LockSequence performs the full ENQ/ACK handshake and command exchange
-func (lock *SaltoLockServer) LockSequence() error {
+func (lock *SaltoLockServer) LockSequence(conn net.Conn) error {
 	const timeout = 10 * time.Second
 	var (
 		resp    []byte
+		reader  = bufio.NewReader(conn)
 		drained = 0 // count of stale frames consumed across waits
 	)
 
-	conn, err := InitializeServerConnection(LockServerURL)
-	if err != nil {
-		return err
-	}
-	defer conn.Close()
-	
-	reader  := bufio.NewReader(conn)
-
 	// 1. Send ENQ
 	log.Infof("Sending ENQ")
 	if _, e := conn.Write([]byte{ENQ}); e != nil {

lockserver/tljlockserver.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io/ioutil"
+	"net"
 	"net/http"
 	"net/url"
 	"time"
@@ -35,9 +36,9 @@ func (lock *TLJLockServer) BuildCommand(doorReq DoorCardRequest, checkIn, checkO
 	return nil
 }
 
-func (lock *TLJLockServer) LockSequence() error {
+func (lock *TLJLockServer) LockSequence(conn net.Conn) error {
 	log.Infof("Sending command: %q", lock.command)
-	client := &http.Client{Timeout: 30 * time.Second}
+	client := &http.Client{Timeout: 10 * time.Second}
 	resp, err := client.Get(lock.command)
 	if err != nil {
 		return fmt.Errorf("HTTP request failed: %v", err)

main.go

@@ -1,11 +1,12 @@
 package main
 
 import (
-	"bytes"
+	// "database/sql"
 	"encoding/json"
 	"encoding/xml"
 	"fmt"
 	"io"
+	"net"
 	"net/http"
 	"os"
 	"os/exec"
@@ -29,7 +30,7 @@ import (
 )
 
 const (
-	buildVersion   = "1.0.18"
+	buildVersion   = "1.0.11"
 	serviceName    = "hardlink"
 	customLayout   = "2006-01-02 15:04:05 -0700"
 	transactionUrl = "http://127.0.0.1:18181/start-transaction/"
@@ -51,15 +52,15 @@ type configRec struct {
 
 // App holds shared resources.
 type App struct {
-	configRec  configRec
 	dispPort   *serial.Port
+	lockConn   net.Conn
 	lockserver lockserver.LockServer
 }
 
-func newApp(dispPort *serial.Port, config configRec) *App {
+func newApp(dispPort *serial.Port, lockConn net.Conn, config configRec) *App {
 	return &App{
-		configRec:  config,
 		dispPort:   dispPort,
+		lockConn:   lockConn,
 		lockserver: lockserver.NewLockServer(config.LockType, config.EncoderAddress, fatalError),
 	}
 }
@@ -69,6 +70,8 @@ func main() {
 	config := readConfig()
 	printer.Layout = readTicketLayout()
 	printer.PrinterName = config.PrinterName
+
+	var lockConn net.Conn
 	lockserver.Cert = config.Cert
 	lockserver.LockServerURL = config.LockserverUrl
 
@@ -100,19 +103,25 @@ func main() {
 	}
 	log.Infof("Dispenser initialized on port %s, %s", config.DispenserPort, status)
 
-	// Test lock-server connection
+	// Initialize lock-server connection once
 	switch strings.ToLower(config.LockType) {
 	case lockserver.TLJ:
 
 	default:
-		lockConn, err := lockserver.InitializeServerConnection(config.LockserverUrl)
+		lockConn, err = lockserver.InitializeServerConnection(config.LockserverUrl)
 		if err != nil {
 			fatalError(err)
 		}
-		log.Infof("Connectting to lock server at %s", config.LockserverUrl)
+		defer lockConn.Close()
-		lockConn.Close()
+		log.Infof("Connected to lock server at %s", config.LockserverUrl)
 	}
 
+	// db, err := payment.InitMSSQL(config.dbport, config.dbname, config.dbuser, config.dbpassword)
+	// if err != nil {
+	// 	fatalError(fmt.Errorf("DB init failed: %v", err))
+	// }
+	// defer db.Close()
+
 	if config.IsPayment {
 		startClient := func() (*exec.Cmd, error) {
 			cmd := exec.Command("./ChipDNAClient/ChipDnaClient.exe")
@@ -172,7 +181,7 @@ func main() {
 
 	// Create App and wire routes
 	// dispHandle := &serial.Port{} // Placeholder, replace with actual dispenser handle
-	app := newApp(dispHandle, config)
+	app := newApp(dispHandle, lockConn, config)
 
 	mux := http.NewServeMux()
 	setUpRoutes(app, mux)
@@ -232,36 +241,18 @@ func writeError(w http.ResponseWriter, status int, msg string) {
 	json.NewEncoder(w).Encode(theResponse)
 }
 
-func writeTransactionResult(w http.ResponseWriter, status int, theResponse cmstypes.ResponseRec) {
-	w.Header().Set("Content-Type", "application/json")
-	w.WriteHeader(status)
-	if err := json.NewEncoder(w).Encode(theResponse); err != nil {
-		logging.Error(serviceName, err.Error(), "JSON encode error", "startTransaction", "", "", 0)
-	}
-}
-
 func (app *App) startTransaction(w http.ResponseWriter, r *http.Request) {
 	const op = logging.Op("startTransaction")
 	var (
 		theResponse       cmstypes.ResponseRec
 		cardholderReceipt string
-		theRequest        cmstypes.TransactionRec
 	)
 
-	theResponse.Status.Code = http.StatusInternalServerError
-	theResponse.Status.Message = "500 Internal server error"
-
 	w.Header().Set("Access-Control-Allow-Origin", "*")
 	w.Header().Set("Access-Control-Allow-Methods", "POST, OPTIONS")
 	w.Header().Set("Access-Control-Allow-Headers", "Content-Type")
 	w.Header().Set("Content-Type", "application/json")
 
-	if !app.configRec.IsPayment {
-		theResponse.Data = payment.BuildFailureURL(payment.ResultError, "Payment processing is disabled")
-		writeTransactionResult(w, http.StatusServiceUnavailable, theResponse)
-		return
-	}
-
 	if r.Method == http.MethodOptions {
 		w.WriteHeader(http.StatusNoContent)
 		return
@@ -269,43 +260,29 @@ func (app *App) startTransaction(w http.ResponseWriter, r *http.Request) {
 
 	log.Println("startTransaction called")
 	if r.Method != http.MethodPost {
-		theResponse.Data = payment.BuildFailureURL(payment.ResultError, "Method not allowed; use POST")
+		writeError(w, http.StatusMethodNotAllowed, "Method not allowed; use POST")
-		writeTransactionResult(w, http.StatusMethodNotAllowed, theResponse)
 		return
 	}
 	defer r.Body.Close()
 
 	if ct := r.Header.Get("Content-Type"); ct != "text/xml" {
-		theResponse.Data = payment.BuildFailureURL(payment.ResultError, "Content-Type must be text/xml")
+		writeError(w, http.StatusUnsupportedMediaType, "Content-Type must be text/xml")
-		writeTransactionResult(w, http.StatusUnsupportedMediaType, theResponse)
 		return
 	}
 
-	body, _ := io.ReadAll(r.Body)
+	client := &http.Client{Timeout: 90 * time.Second}
-	err := xml.Unmarshal(body, &theRequest)
+	response, err := client.Post(transactionUrl, "text/xml", r.Body)
-	if err != nil {
-		logging.Error(serviceName, err.Error(), "ReadXML", string(op), "", "", 0)
-		theResponse.Data = payment.BuildFailureURL(payment.ResultError, "Invalid XML payload")
-		writeTransactionResult(w, http.StatusBadRequest, theResponse)
-		return
-	}
-	log.Printf("Start trnasaction payload: Amount=%s, Type=%s", theRequest.AmountMinorUnits, theRequest.TransactionType)
-
-	client := &http.Client{Timeout: 300 * time.Second}
-	response, err := client.Post(transactionUrl, "text/xml", bytes.NewBuffer(body))
 	if err != nil {
 		logging.Error(serviceName, err.Error(), "Payment processing error", string(op), "", "", 0)
-		theResponse.Data = payment.BuildFailureURL(payment.ResultError, "No response from payment processor")
+		writeError(w, http.StatusInternalServerError, "Payment processing failed: "+err.Error())
-		writeTransactionResult(w, http.StatusBadGateway, theResponse)
 		return
 	}
 	defer response.Body.Close()
 
-	body, err = io.ReadAll(response.Body)
+	body, err := io.ReadAll(response.Body)
 	if err != nil {
 		logging.Error(serviceName, err.Error(), "Read response body error", string(op), "", "", 0)
-		theResponse.Data = payment.BuildFailureURL(payment.ResultError, "Failed to read response body")
+		writeError(w, http.StatusInternalServerError, "Failed to read response body: "+err.Error())
-		writeTransactionResult(w, http.StatusInternalServerError, theResponse)
 		return
 	}
 
@@ -315,11 +292,10 @@ func (app *App) startTransaction(w http.ResponseWriter, r *http.Request) {
 	result := make(map[string]string)
 	for _, e := range responseEntries {
 		switch e.Key {
-		case payment.ReceiptData, payment.ReceiptDataMerchant:
+		case "RECEIPT_DATA", "RECEIPT_DATA_MERCHANT":
-			// ignore these
+		case "RECEIPT_DATA_CARDHOLDER":
-		case payment.ReceiptDataCardholder:
 			cardholderReceipt = e.Value
-		case payment.TransactionResult:
+		case "TRANSACTION_RESULT":
 			theResponse.Status.Message = e.Value
 			theResponse.Status.Code = http.StatusOK
 			result[e.Key] = e.Value
@@ -332,8 +308,18 @@ func (app *App) startTransaction(w http.ResponseWriter, r *http.Request) {
 		log.Errorf("PrintCardholderReceipt error: %v", err)
 	}
 
+	// Insert into DB
+	// if err := payment.InsertTransactionRecord(r.Context(), app.db, result); err != nil {
+	// 	log.Errorf("DB insert error: %v", err)
+	// }
+
 	theResponse.Data = payment.BuildRedirectURL(result)
-	writeTransactionResult(w, http.StatusOK, theResponse)
+
+	w.Header().Set("Content-Type", "application/json")
+	w.WriteHeader(http.StatusOK)
+	if err := json.NewEncoder(w).Encode(theResponse); err != nil {
+		logging.Error(serviceName, err.Error(), "JSON encode error", string(op), "", "", 0)
+	}
 }
 
 func (app *App) issueDoorCard(w http.ResponseWriter, r *http.Request) {
@@ -403,7 +389,7 @@ func (app *App) issueDoorCard(w http.ResponseWriter, r *http.Request) {
 	app.lockserver.BuildCommand(doorReq, checkIn, checkOut)
 
 	// lock server sequence
-	err = app.lockserver.LockSequence()
+	err = app.lockserver.LockSequence(app.lockConn)
 	if err != nil {
 		logging.Error(serviceName, err.Error(), "Key encoding", string(op), "", "", 0)
 		writeError(w, http.StatusBadGateway, err.Error())

payment/creditcall.go

@@ -16,11 +16,6 @@ import (
 )
 
 const (
-	// Transaction types
-	SaleTransactionType     = "sale"
-	AccountVerificationType = "account verification"
-
-	// Transaction results
 	ResultApproved              = "approved"
 	ResultDeclined              = "declined"
 	ResultCancelled             = "cancelled"
@@ -28,24 +23,6 @@ const (
 	ResultError                 = "error"
 	CheckinSuccessfulEndpoint   = "/successful" // Endpoint to send guest to after successful payment
 	CheckinUnsuccessfulEndpoint = "/unsuccessful"
-
-	// Response map keys
-	CardReference         = "CARD_REFERENCE"
-	CardHash              = "CARD_HASH"
-	Errors                = "ERRORS"
-	ReceiptData           = "RECEIPT_DATA"
-	ReceiptDataMerchant   = "RECEIPT_DATA_MERCHANT"
-	ReceiptDataCardholder = "RECEIPT_DATA_CARDHOLDER"
-	Reference             = "REFERENCE"
-	TransactionResult     = "TRANSACTION_RESULT"
-	TransactionType       = "TRANSACTION_TYPE"
-	ConfirmResult         = "CONFIRM_RESULT"
-	ConfirmErrors         = "CONFIRM_ERRORS"
-
-	// Log field keys
-	LogFieldError       = "error"
-	LogFieldDescription = "description"
-	LogResult           = "transactionResult"
 )
 
 // XML parsing structs
@@ -65,14 +42,6 @@ type (
 		Key   string `xml:"Key"`
 		Value string `xml:"Value"`
 	}
-
-	TransactionConfirmation struct {
-		XMLName               xml.Name `xml:"TransactionConfirmation"`
-		Result                string   `xml:"Result"`
-		Errors                string   `xml:"Errors"`
-		ErrorDescription      string   `xml:"ErrorDescription"`
-		ReceiptDataCardholder string   `xml:"ReceiptDataCardholder"`
-	}
 )
 
 // ParseTransactionResult parses the XML into entries.
@@ -248,70 +217,65 @@ func nullableFloatArg(nf sql.NullFloat64) interface{} {
 	return nil
 }
 
-// BuildRedirectURL builds the redirect URL to send the guest to after payment.
 func BuildRedirectURL(result map[string]string) string {
-	res := result[TransactionResult]
+	// 1) normalize the result code
-	tType := result[TransactionType]
+	res := strings.ToLower(result["TRANSACTION_RESULT"])
 
-	// Transaction approved?
+	// 2) pick base path and optional error params
-	if strings.EqualFold(res, ResultApproved) {
+	var basePath string
-		switch {
+	var msgType, description string
-		// Transaction type AccountVerification?
-		case strings.EqualFold(tType, AccountVerificationType):
-			log.WithField(LogResult, result[TransactionResult]).
-				Info("Account verification approved")
 
-			return buildSuccessURL(result)
+	switch res {
+	case ResultApproved:
+		basePath = CheckinSuccessfulEndpoint
 
-		// Transaction type Sale?
+	case ResultDeclined:
-		case strings.EqualFold(tType, SaleTransactionType):
+		basePath = CheckinUnsuccessfulEndpoint
-			// Transaction confirmed?
+		msgType = "declined"
-			if strings.EqualFold(result[ConfirmResult], ResultApproved) {
+		description = "payment declined"
-				log.WithField(LogResult, result[ConfirmResult]).
-					Info("Transaction approved and confirmed")
 
-				return buildSuccessURL(result)
+	case ResultCancelled:
-			}
+		basePath = CheckinUnsuccessfulEndpoint
+		msgType = "cancelled"
+		description = "payment cancelled by customer"
 
-			// Not confirmed
+	case ResultPending:
-			log.WithFields(log.Fields{LogFieldError: result[ConfirmResult], LogFieldDescription: result[ConfirmErrors]}).
+		// you could choose to treat pending as unsuccessful or special-case it
-				Error("Transaction approved but not confirmed")
+		basePath = CheckinUnsuccessfulEndpoint
+		msgType = "pending"
+		description = "payment pending"
+	case ResultError:
+		basePath = CheckinUnsuccessfulEndpoint
+		msgType = "error"
+		description = result["ERROR"]
 
-			return BuildFailureURL(result[ConfirmResult], result[ConfirmErrors])
+	default:
-		}
+		basePath = CheckinUnsuccessfulEndpoint
+		msgType = "error"
+		description = "unknown transaction result"
 	}
 
-	// Not approved
+	if msgType != "" {
-	return BuildFailureURL(res, result[Errors])
+		log.Warnf("Transaction %s: %s - %s", res, msgType, description)
-}
+	}
 
-func buildSuccessURL(result map[string]string) string {
+	// 3) build query params
 	q := url.Values{}
-	q.Set("TxnReference", result[Reference])
+	q.Set("TxnReference", result["REFERENCE"])
-	q.Set("CardHash", hex.EncodeToString([]byte(result[CardHash])))
+	q.Set("CardHash", hex.EncodeToString([]byte(result["CARD_HASH"])))
-	q.Set("CardReference", hex.EncodeToString([]byte(result[CardReference])))
+	q.Set("CardReference", hex.EncodeToString([]byte(result["CARD_REFERENCE"])))
-	return (&url.URL{
-		Path:     CheckinSuccessfulEndpoint,
-		RawQuery: q.Encode(),
-	}).String()
-}
 
-func BuildFailureURL(msgType, description string) string {
+	// only append these when non-approved
-	q := url.Values{}
+	if msgType != "" {
-	if msgType == "" {
+		q.Set("MsgType", msgType)
-		msgType = ResultError
+		q.Set("Description", description)
-	}
-	if description == "" {
-		description = "Transaction failed"
 	}
 
-	log.WithFields(log.Fields{LogFieldError: msgType, LogFieldDescription: description}).
+	// 4) assemble final URL
-		Error("Transaction failed")
+	// note: url.URL automatically escapes values in RawQuery
-
+	u := url.URL{
-	q.Set("MsgType", msgType)
+		Path:     basePath,
-	q.Set("Description", description)
-	return (&url.URL{
-		Path:     CheckinUnsuccessfulEndpoint,
 		RawQuery: q.Encode(),
-	}).String()
+	}
+	return u.String()
 }

release notes.md

@@ -2,56 +2,38 @@
 
 builtVersion is a const in main.go
 
-#### 1.0.18 - 04 September 2025
+#### 1.0.11 - 11 August 2024
-increased timeout for TLJ lock server connection to 30 seconds
-
-#### 1.0.17 - 30 August 2025
-added functionality to commit transactions
-
-#### 1.0.15 - 27 August 2025
-fixed TCP/IP connection to the lock server
-
-#### 1.0.14 - 21 August 2025
-fixed issue in creditcall payment processing where error description was not properly set
-
-#### 1.0.13 - 21 August 2025
-TCP/IP connection to the lock server is now established before encoding the keycard and closedafter the encoding is done.
-
-#### 1.0.12 - 11 August 2025
-added delay before checking dispenser status
-
-#### 1.0.11 - 11 August 2025
 updated Salto key encoding workflow
 
-#### 1.0.10 - 08 August 2025
+#### 1.0.10 - 08 August 2024
 updated logging for TLJ locks
 
-#### 1.0.9 - 08 August 2025
+#### 1.0.9 - 08 August 2024
 added TLJ lock server and implemented workflow for TLJ locks
 
-#### 1.0.8 - 01 August 2025
+#### 1.0.8 - 01 August 2024
 improved error handling and logging in Salto
 
-#### 1.0.7 - 25 July 2025
+#### 1.0.7 - 25 July 2024
 added check if the room exists
 
-#### 1.0.6 - 25 July 2025
+#### 1.0.6 - 25 July 2024
 updated workflow for Salto locks
 
-#### 1.0.5 - 24 July 2025
+#### 1.0.5 - 24 July 2024
 added encoding keycard copy for Salto locks
 
-#### 1.0.4 - 22 July 2025
+#### 1.0.4 - 22 July 2024
 added salto lock server and implemented workflow for Salto 
 
-#### 1.0.0 - 30 June 2025
+#### 1.0.0 - 30 June 2024
 added creditcall payment method 
  `/starttransaction` - API payment endpoint to start a transaction 
 
-#### 0.9.1 - 22 May 2025
+#### 0.9.1 - 22 May 2024
 added lockserver interface and implemented workflow for Omnitec 
 
-#### 0.9.0 - 22 May 2025
+#### 0.9.0 - 22 May 2024
 The new API has two new endpoints:
 - `/issuedoorcard` - encoding the door card for the room.
 - `/printroomticket` - printing the room ticket.