http-gstatus.go

// Copyright 2017 Inca Roads LLC.  All rights reserved.
// Use of this source code is governed by licenses granted by the
// copyright holder including that found in the LICENSE file.

// Inbound support for the "/gateway/<gatewayid>" HTTP topic
package main

import (
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"os"
)

// Handle inbound HTTP requests to fetch log files
func inboundWebGatewayUpdateHandler(rw http.ResponseWriter, req *http.Request) {
	stats.Count.HTTP++

	// We have an update request
	body, err := io.ReadAll(req.Body)
	if err != nil {
		fmt.Printf("GW: Error reading HTTP request body: \n%v\n", req)
		return
	}

	// Unmarshal it
	var ttg TTGateReq

	err = json.Unmarshal(body, &ttg)
	if err != nil {
		fmt.Printf("*** Received badly formatted Device Update request:\n%v\n", body)
		return
	}

	requestor, _, abusive := getRequestorIPv4(req)
	if abusive {
		return
	}

	fmt.Printf("\n%s Received gateway update for %s %s (%s)\n", LogTime(), ttg.GatewayID, ttg.GatewayName, ttg.GatewayRegion)

	go WriteGatewayStatus(ttg, requestor)
	stats.Count.HTTPGUpdate++
}

// Handle inbound HTTP requests to fetch log files
func inboundWebGatewayStatusHandler(rw http.ResponseWriter, req *http.Request) {
	stats.Count.HTTP++

	// Set response mime type
	rw.Header().Set("Content-Type", "application/json")

	// Log it
	if len(req.RequestURI) > len(TTServerTopicGatewayStatus) {
		filename := req.RequestURI[len(TTServerTopicGatewayStatus):]
		if filename != "" {

			fmt.Printf("%s Gateway information request for %s\n", LogTime(), filename)

			// Open the file
			file := SafecastDirectory() + TTGatewayStatusPath + "/" + filename + ".json"
			fd, err := os.Open(file)
			if err != nil {
				io.WriteString(rw, ErrorString(err))
				return
			}
			defer fd.Close()

			// Copy the file to output
			io.Copy(rw, fd)
			return

		}
	}

}