forge/send.go

// Copyright 2024 WIT.COM Inc Licensed GPL 3.0

package main

import (
	"strings"

	"go.wit.com/lib/protobuf/forgepb"
	"go.wit.com/log"
)

func sendPatches(pset *forgepb.Patchs) error {
	var url string
	url = me.urlbase + "/patchset"
	msg, err := pset.Marshal()
	if err != nil {
		log.Info("proto.Marshal() failed:", err)
		return err
	}
	log.Info("proto.Marshal() msg len", len(msg))
	body, err := httpPost(url, msg)
	if err != nil {
		log.Info("httpPost() failed:", err)
		return err
	}

	test := strings.TrimSpace(string(body))
	// log.Info("virtigo returned body:", test)
	for _, line := range strings.Split(test, "\n") {
		log.Info("got back:", line)
	}
	return nil
}

func listPatches() error {
	var url string
	url = me.urlbase + "/patchsetlist"
	body, err := httpPost(url, nil)
	if err != nil {
		log.Info("httpPost() failed:", err)
		return err
	}

	var last string
	test := strings.TrimSpace(string(body))
	for _, line := range strings.Split(test, "\n") {
		log.Info("patchset:", line)
		last = strings.TrimSpace(line)
	}
	getPatch(last)
	return nil
}

func getPatch(pbfile string) error {
	url := me.urlbase + "/patchsetget?filename=" + pbfile
	log.Info("getPatch() url", url)
	body, err := httpPost(url, nil)
	if err != nil {
		log.Info("httpPost() failed:", err)
		return err
	}
	log.Info("getPatch() len(body)", len(body))
	return nil
}

func sendDevelDiff() {
	pset, err := me.forge.MakeDevelPatchSet()
	if err != nil {
		badExit(err)
	}
	if err := sendPatches(pset); err != nil {
		badExit(err)
	}

	/*
		all := pset.SortByFilename()
		for all.Scan() {
			p := all.Next()
			log.Info("read in patch:", p.Filename)
		}
		err = me.forge.SendPatchSet(pset)
		if err != nil {
			badExit(err)
		}
	*/
}

func sendMasterDiff() {
	pset, err := me.forge.MakeMasterPatchSet()
	if err != nil {
		badExit(err)
	}
	all := pset.SortByFilename()
	for all.Scan() {
		p := all.Next()
		log.Info("read in patch:", p.Filename)
	}
	err = me.forge.SendPatchSet(pset)
	if err != nil {
		badExit(err)
	}
}