TechEmpower.FrameworkBenchmarks/frameworks/Java/gemini/Source/hello/home/handler/HelloHandler.java

package hello.home.handler;

import java.util.*;
import java.util.concurrent.*;

import com.techempower.cache.*;
import com.techempower.gemini.*;
import com.techempower.gemini.path.*;
import com.techempower.gemini.path.annotation.*;

import hello.home.entity.*;

/**
 * Handles the various framework benchmark request types.
 */
public class HelloHandler
    extends  MethodSegmentHandler<Context>
{

  private static final int DB_ROWS = 10000;
  
  private final EntityStore store;
  
  /**
   * Constructor.
   */
  public HelloHandler(GeminiApplication app)
  {
    super(app, "hllo");
    this.store = app.getStore();
  }
  
  @PathDefault
  public boolean test()
  {
    return false;
  }
  
  /**
   * Return "hello world" as a JSON-encoded message.
   */
  @PathSegment("json")
  public boolean helloworld()
  {
    final Map<String,String> resp = new HashMap<>(1);
    resp.put(GeminiConstants.GEMINI_MESSAGE, "Hello, World!");
    
    return json(resp);
  }

  /**
   * Return a single World objects as JSON, selected randomly from the World
   * table.  Assume the table has 10,000 rows.
   */
  @PathSegment
  public boolean db()
  {
    return json(store.get(World.class, ThreadLocalRandom.current().nextInt(DB_ROWS) + 1));
  }

  /**
   * Return a list of World objects as JSON, selected randomly from the World
   * table.  Assume the table has 10,000 rows.
   */
  @PathSegment("query")
  public boolean multipleQueries()
  {
    final Random random = ThreadLocalRandom.current();
    final int queries = query().getInt("queries", 1, 1, 500);
    final World[] worlds = new World[queries];

    for (int i = 0; i < queries; i++)
    {
      worlds[i] = store.get(World.class, random.nextInt(DB_ROWS) + 1);
    }
    
    return json(worlds);
  }

  /**
   * Return a list of World objects as JSON, selected randomly from the World
   * table.  Assume the table has 10,000 rows.
   */
  @PathSegment("cached_query")
  public boolean multipleCachedQueries()
  {
    final Random random = ThreadLocalRandom.current();
    final int queries = query().getInt("queries", 1, 1, 500);
    final CachedWorld[] worlds = new CachedWorld[queries];

    for (int i = 0; i < queries; i++)
    {
      worlds[i] = store.get(CachedWorld.class, random.nextInt(DB_ROWS) + 1);
    }

    return json(worlds);
  }
  
  /**
   * Fetch the full list of Fortunes from the database, sort them by the
   * fortune message text, and then render the results to simple HTML using a 
   * server-side template.
   */
  @PathSegment
  public boolean fortunes()
  {
    final List<Fortune> fortunes = store.list(Fortune.class);
    fortunes.add(new Fortune().setMessage("Additional fortune added at request time."));
    Collections.sort(fortunes);
    return mustache("fortunes", fortunes);
  }

  /**
   * Return a list of World objects as JSON, selected randomly from the World
   * table.  For each row that is retrieved, that row will have its 
   * randomNumber field updated and then the row will be persisted.  We
   * assume the table has 10,000 rows.
   */
  @PathSegment
  public boolean update()
  {
    final Random random = ThreadLocalRandom.current();
    final int queries = query().getInt("queries", 1, 1, 500);
    final World[] worlds = new World[queries];

    for (int i = 0; i < queries; i++)
    {
      worlds[i] = store.get(World.class, random.nextInt(DB_ROWS) + 1);
      worlds[i].setRandomNumber(random.nextInt(DB_ROWS) + 1);
    }

    store.putAll(Arrays.asList(worlds));
    
    return json(worlds);
  }
  
  /**
   * Responds with a plaintext "Hello, World!" 
   */
  @PathSegment
  public boolean plaintext()
  {
    return text("Hello, World!");
  }

}