logs.go

/*
This file is part of the Gadget command-line tools.
Copyright (C) 2017 Next Thing Co.

Gadget 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 2 of the License, or
(at your option) any later version.

Gadget 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 Gadget.  If not, see <http://www.gnu.org/licenses/>.
*/

package main

import (
	"errors"
	"fmt"
	"github.com/nextthingco/libgadget"
	log "gopkg.in/sirupsen/logrus.v1"
)

// Process the build arguments and execute build
func GadgetLogs(args []string, g *libgadget.GadgetContext) error {

	libgadget.EnsureKeys()

	client, err := libgadget.GadgetLogin(libgadget.GadgetPrivKeyLocation)

	if err != nil {
		return err
	}

	log.Info("Retrieving logs:")

	logsFailed := false

	stagedContainers, _ := libgadget.FindStagedContainers(args, append(g.Config.Onboot, g.Config.Services...))
	for _, container := range stagedContainers {
		commandFormat := `docker logs %s`
		cmd := fmt.Sprintf(commandFormat, container.Alias)

		stdout, stderr, err := libgadget.RunRemoteCommand(client, cmd)

		if err != nil {

			// fail loudly, but continue

			logsFailed = true

			log.Errorf("Failed to fetch '%s' logs on Gadget", container.Name)
			log.Warn("Was the container ever deployed?")

			log.WithFields(log.Fields{
				"function":    "GadgetLogs",
				"name":        container.Alias,
				"start-stage": "docker logs",
			}).Debug("This is likely due to specifying containers for deploying, but trying to fetch all logs")

		} else {

			log.Infof("  Begin '%s' logs\n", container.Name)
			log.Infof("\n%s", stdout)
			log.Warnf("\n%s", stderr)
			log.Infof("  End '%s' logs", container.Name)

		}
	}

	if logsFailed {
		err = errors.New("Failed to fetch logs for one or more containers")
	}

	return err
}