milagan/MojoMVC

package MyApp;

use strict;
use warnings;

use Mojo::Base 'Mojolicious';
use ZMQ::LibZMQ3;
use ZMQ::Constants qw|ZMQ_PUB ZMQ_SUB ZMQ_SUBSCRIBE ZMQ_FD ZMQ_NOBLOCK|;
use MojoX::Log::Log4perl;
use MyApp::Model::Data;
use MyApp::Service::RestService;

use File::Basename 'dirname';
use File::Spec::Functions 'catdir';
use File::Spec;

our $VERSION = '1.0';

# This method will run once at server start
sub startup {
  my $self = shift;
  
  # Create model instance
  my $model = new MyApp::Model::Data($self);
  $model->open();

  # Create service instance
  my $service = new MyApp::Service::RestService($self);  

  # Switch to installable home directory
  $self->home->parse(catdir(dirname(__FILE__), 'MyApp'));
  
  # Switch to installable "public" directory
  $self->static->paths->[0] = $self->home->rel_dir('public');

  # Switch to installable "templates" directory
  $self->renderer->paths->[0] = $self->home->rel_dir('templates');

  # Initialize ZeroMQ
  my $ctx  = zmq_init();
  my $value = 0;
  
  $self->log( MojoX::Log::Log4perl->new('log.conf'), 'HUP' );

  $self->helper(zmqsock_to_fd => sub {
          my ( $c, $socket ) = @_;
          return my $fh = IO::Handle->new_from_fd($socket->getsockopt(ZMQ_FD),'r');
  });

  $self->helper(subscribe_socket => sub { return $self->init_subscribe_socket($ctx); });
  $self->helper(publish_socket   => sub { return $self->init_publish_socket($ctx); });
  $self->helper(get_value => sub { return $value; });
  $self->helper(inc_value => sub { return ++$value; });
  $self->helper(model => sub { return $model; }); 
  $self->helper(service => sub { return $service; });

  my $s = $self->init_publish_socket($ctx);
  Mojo::IOLoop->recurring(0.2 => sub {
        zmq_msg_send('hello world', $s, ZMQ_NOBLOCK);
  });

  $self->plugin('PODRenderer');
  $self->plugin("OpenAPI" => {    
    url => $self->home->rel_file("api.json")
  });    

  # Router
  my $r = $self->routes;

  # Normal route to controller
  $r->get('/')->to('example#welcome'); 
  $r->get('/helper')->to('example#helper');
  $r->get('/value')->to('example#value');
  $r->get('/incvalue')->to('example#incvalue');
  $r->websocket('echo')->to('example#echo');  
  $r->get('/write_sqlitedb')->to('example#write_sqlitedb');
  $r->get('/read_sqlitedb')->to('example#read_sqlitedb');
  $r->get('/get_restapi_blocking')->to('service#get_restapi_blocking');
  $r->get('/get_restapi_nonblocking')->to('service#get_restapi_nonblocking');
}

sub init_publish_socket {
  my ( $self, $ctx ) = @_;
  my $socket = zmq_socket($ctx, ZMQ_PUB);

  zmq_bind($socket, 'tcp://*:5555');

  return $socket;
}

sub init_subscribe_socket {
  my ( $self, $ctx ) = @_;
  my $socket = $ctx->socket(ZMQ_SUB);

  $socket->setsockopt(ZMQ_SUBSCRIBE,'');
  $socket->connect('tcp://127.0.0.1:5556');

  return $socket;
}
1;