X-Git-Url: https://ruderich.org/simon/gitweb/?a=blobdiff_plain;f=cmd%2Fsafcm%2Fsync_info.go;fp=cmd%2Fsafcm%2Fsync_info.go;h=b0a85ee507f4603b2966eb0b7b6e8b6f74dba12a;hb=f2f2bc47e8729548f3c10117f7f008b547c4afc5;hp=0000000000000000000000000000000000000000;hpb=dc0d431a778a50e6732b9eb91384a07a207b772d;p=safcm%2Fsafcm.git diff --git a/cmd/safcm/sync_info.go b/cmd/safcm/sync_info.go new file mode 100644 index 0000000..b0a85ee --- /dev/null +++ b/cmd/safcm/sync_info.go @@ -0,0 +1,63 @@ +// "sync" sub-command: collect information from remote host + +// Copyright (C) 2021 Simon Ruderich +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program. If not, see . + +package main + +import ( + "fmt" + "regexp" + "strings" + + "ruderich.org/simon/safcm" + "ruderich.org/simon/safcm/cmd/safcm/config" + "ruderich.org/simon/safcm/rpc" +) + +func (s *Sync) hostInfo(conn *rpc.Conn) ([]string, error) { + x, err := s.sendRecv(conn, safcm.MsgInfoReq{ + LogLevel: s.config.LogLevel, + DetectGroups: s.config.DetectGroups, + }) + if err != nil { + return nil, err + } + resp, ok := x.(safcm.MsgInfoResp) + if !ok { + return nil, fmt.Errorf("unexpected response %v", x) + } + if resp.Error != "" { + return nil, fmt.Errorf("%s", resp.Error) + } + return hostInfoRespToGroups(resp), nil +} + +// Keep in sync with config/groups.go:groupNameRegexp +var infoGroupDetectedRegexp = regexp.MustCompile(`[^a-z0-9_-]+`) + +func hostInfoRespToGroups(resp safcm.MsgInfoResp) []string { + groups := []string{ + config.GroupDetectedPrefix + "_" + resp.Goos, + config.GroupDetectedPrefix + "_" + resp.Goarch, + } + for _, x := range resp.Output { + x = strings.TrimSpace(x) + x = strings.ToLower(x) + x = infoGroupDetectedRegexp.ReplaceAllString(x, "_") + groups = append(groups, config.GroupDetectedPrefix+"_"+x) + } + return groups +}