Coverage Report - com.thindeck.agents.CheckState
 
Classes in this File Line Coverage Branch Coverage Complexity
CheckState
15%
4/26
0%
0/6
1.75
 
 1  2 
 /**
 2   
  * Copyright (c) 2014-2015, Thindeck.com
 3   
  * All rights reserved.
 4   
  *
 5   
  * Redistribution and use in source and binary forms, with or without
 6   
  * modification, are permitted provided that the following conditions
 7   
  * are met: 1) Redistributions of source code must retain the above
 8   
  * copyright notice, this list of conditions and the following
 9   
  * disclaimer. 2) Redistributions in binary form must reproduce the above
 10   
  * copyright notice, this list of conditions and the following
 11   
  * disclaimer in the documentation and/or other materials provided
 12   
  * with the distribution. 3) Neither the name of the thindeck.com nor
 13   
  * the names of its contributors may be used to endorse or promote
 14   
  * products derived from this software without specific prior written
 15   
  * permission.
 16   
  *
 17   
  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 18   
  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT
 19   
  * NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
 20   
  * FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
 21   
  * THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
 22   
  * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
 23   
  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
 24   
  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 25   
  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
 26   
  * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 27   
  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
 28   
  * OF THE POSSIBILITY OF SUCH DAMAGE.
 29   
  */
 30   
 package com.thindeck.agents;
 31   
 
 32   
 import com.jcabi.aspects.Immutable;
 33   
 import com.jcabi.immutable.ArrayMap;
 34   
 import com.jcabi.log.Logger;
 35   
 import com.jcabi.xml.XML;
 36   
 import com.thindeck.api.Agent;
 37   
 import java.io.IOException;
 38   
 import java.util.Collection;
 39   
 import org.xembly.Directive;
 40   
 import org.xembly.Directives;
 41   
 
 42   
 /**
 43   
  * Check state of Docker containers.
 44   
  *
 45   
  * @author Yegor Bugayenko (yegor@teamed.io)
 46   
  * @version $Id$
 47   
  * @since 0.5
 48   
  * @checkstyle MultipleStringLiteralsCheck (500 lines)
 49   
  */
 50   
 @Immutable
 51   
 public final class CheckState implements Agent {
 52   
 
 53   
     /**
 54   
      * Script to use.
 55   
      */
 56   
     private final transient Script script;
 57   
 
 58   
     /**
 59   
      * Ctor.
 60   
      * @throws IOException If fails
 61   
      */
 62   
     public CheckState() throws IOException {
 63  0 
         this(
 64   
             new Script.Default(
 65   
                 CheckState.class.getResource("check-state.sh")
 66   
             )
 67   
         );
 68  0 
     }
 69   
 
 70   
     /**
 71   
      * Ctor.
 72   
      * @param spt Script.
 73   
      */
 74  1 
     public CheckState(final Script spt) {
 75  1 
         this.script = spt;
 76  1 
     }
 77   
 
 78   
     @Override
 79   
     public Iterable<Directive> exec(final XML deck) throws IOException {
 80  0 
         final Directives dirs = new Directives();
 81  0 
         final Collection<XML> containers = deck.nodes(
 82   
             "/deck/containers/container[host and http]"
 83   
         );
 84  0 
         final String today = new Today().iso();
 85  0 
         for (final XML ctr : containers) {
 86  0 
             final Integer port = Integer.parseInt(
 87   
                 ctr.xpath("http/text()").get(0)
 88   
             );
 89  0 
             final String host = ctr.xpath("host/text()").get(0);
 90  0 
             dirs.xpath(
 91   
                 String.format(
 92   
                     "/deck/containers/container[name='%s']",
 93   
                     ctr.xpath("name/text()").get(0)
 94   
                 )
 95   
             );
 96  0 
             final String before = ctr.xpath("@state").get(0);
 97  0 
             final String after = this.state(host, port);
 98  0 
             if (!after.equals(before)) {
 99  0 
                 dirs.attr("state", after).attr("checked", today);
 100  0 
                 Logger.info(
 101   
                     this, "State of container %s changed from %s to %s",
 102   
                     ctr.xpath("name/text()").get(0), before, after
 103   
                 );
 104   
             }
 105  0 
         }
 106  0 
         return dirs;
 107   
     }
 108   
 
 109   
     /**
 110   
      * Get state.
 111   
      * @param host Host name of the tank
 112   
      * @param port Port to check (HTTP)
 113   
      * @return State
 114   
      * @throws IOException If fails
 115   
      */
 116   
     private String state(final String host, final int port) throws IOException {
 117  0 
         final String stdout = this.script.exec(
 118   
             host,
 119   
             new ArrayMap<String, String>().with("port", Integer.toString(port))
 120   
         );
 121   
         final String state;
 122  0 
         if (stdout.contains("DEAD")) {
 123  0 
             state = "dead";
 124  0 
             Logger.info(
 125   
                 this, "HTTP port %d at %s doesn't respond",
 126   
                 port, host
 127   
             );
 128   
         } else {
 129  0 
             state = "alive";
 130   
         }
 131  0 
         return state;
 132   
     }
 133   
 
 134   
 }
Report generated by Cobertura 2.0.3 on 12/22/15 7:35 PM.