Skip to content
Snippets Groups Projects
Select Git revision
  • 57fb70b7f08122b2acd6d548659a2726b7ea42e5
  • develop default protected
  • congestioncontrol
  • merge-v-data-collection-spammer-0.8.2
  • WIP-merge-v-data-collection-spammer-0.8.2
  • merge-v-data-collection-spammer-0.7.7
  • tmp
  • test-masterpow-fixing
  • test-masterpow
  • test-echo
  • v-data-collection
  • v-data-collection-spammer
  • tmp-dump-spam-info
  • dump-msg-info-0.3.1
  • test-dump-message-info
  • spammer-exprandom
  • extra/tutorial
  • without_tipselection
  • hacking-docker-network
  • hacking-docker-network-0.2.3
  • master
  • v0.2.3
22 results

dapp.go

Blame
  • plugin.go 1.01 KiB
    package webapi
    
    import (
    	"context"
    	"time"
    
    	"github.com/iotaledger/hive.go/daemon"
    	"github.com/iotaledger/hive.go/logger"
    	"github.com/iotaledger/hive.go/node"
    	"github.com/labstack/echo"
    )
    
    var PLUGIN = node.NewPlugin("WebAPI", node.Enabled, configure, run)
    var log = logger.NewLogger("WebAPI")
    
    var Server = echo.New()
    
    func configure(plugin *node.Plugin) {
    	Server.HideBanner = true
    	Server.HidePort = true
    	Server.GET("/", IndexRequest)
    }
    
    func run(plugin *node.Plugin) {
    	log.Info("Starting Web Server ...")
    
    	daemon.BackgroundWorker("WebAPI Server", func(shutdownSignal <-chan struct{}) {
    		log.Info("Starting Web Server ... done")
    
    		go func() {
    			if err := Server.Start(":8080"); err != nil {
    				log.Info("Stopping Web Server ... done")
    			}
    		}()
    
    		<-shutdownSignal
    
    		log.Info("Stopping Web Server ...")
    		ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
    		defer cancel()
    
    		if err := Server.Shutdown(ctx); err != nil {
    			log.Errorf("Couldn't stop server cleanly: %s", err.Error())
    		}
    	})
    }