Open Source Projects Europe

#!/usr/bin/perl

use strict;

my $SRC='/Users/robert.lill/workspace/alfred/personalization-manager/src/main/java/eu/alfred/personalization_manager/webservices/PersonalizationManagerService.java';

my $TRG='/Users/robert.lill/workspace/alfred/mobileassistantfoundation/personalizationmanagerapi/src/main/java/alfred/eu/personalizationmanagerapi';

my $PAS='/Users/robert.lill/workspace/alfred/mobileassistantfoundation/PersonalAssistantService/src/main/java/eu/alfred/personalassistant/service/personalization';

my $SHR='/Users/robert.lill/workspace/alfred/personalassistantcommons/PersonalAssistantShared/src/main/java/eu/alfred/api/personalization';

my @calls;

my ($path,$method,$description,$response,$name,$args);

my $locmap = {'RequestBody' => 'Field', 'PathVariable' => 'Path'};

sub camelCaseToCapitals($)

{

  my $s = shift;

  my $res = '';

  for my $p (split /([A-Z])/, $s)

  {

    if ($p =~ /[A-Z]/)

    {

      $res .= "_$p";

    }

    else

    {

      $res .= uc($p);

    }

  }

  return $res;

}

open IN, "< $SRC";

my $line;

while ($line = <IN>)

{

  chomp $line;

  if ($line =~ /RequestMapping\s*\(\s*value\s*=\s*"(.*?)"/)

  {

    $path = $1;

  }

  if ($line =~ /method\s*=\s*RequestMethod.(\w+)/)

  {

    $method = $1;

  }

  if ($line =~ /ApiOperation\s*\(\s*value\s*=\s*"(.*?)"/)

  {

    $description = $1;

  }

  if ($line =~ /public\s+ResponseEntity<(List<\w+>|\w+)> (\w+)\((.*)\)/)

  {

    $response = $1;

    $name = $2;

    my @arglist;

    for my $arg (split /,/, $3)

    {

      $arg =~ /@(\w+)\s+(\w+)\s+(\w+)/;

      my $loc = $locmap->{$1};

      push @arglist, {'location' => $loc, 'type' => $2, 'name' => $3};

    }

    $args = \@arglist;

    push @calls, {'path' => $path, 'method' => $method, 'description' => $description, 'name' => $name, 'response' => $response, 'args' => $args};

  }

}

close IN;

sub PMservice()

{

open OUT, "> $TRG/PersonalizationManagerService.java";

print OUT << "EOT";

package alfred.eu.personalizationmanagerapi;

import alfred.eu.personalizationmanagerapi.client.dto.Contact;

import alfred.eu.personalizationmanagerapi.client.dto.Group;

import alfred.eu.personalizationmanagerapi.client.dto.HealthProfile;

import alfred.eu.personalizationmanagerapi.client.dto.Requesters;

import alfred.eu.personalizationmanagerapi.client.dto.UserProfile;

import retrofit.client.Response;

import retrofit.http.DELETE;

import retrofit.http.FormUrlEncoded;

import retrofit.http.GET;

import retrofit.http.POST;

import retrofit.http.PUT;

import retrofit.http.Path;

import retrofit.http.Field;

public interface PersonalizationManagerService {

EOT

for my $rref (@calls)

{

  my $bodyarg = 0;

  my @arglist;

  for my $arg (@{$rref->{'args'}})

  {

    $bodyarg = 1 if ($arg->{'location'} eq 'Field');

    push @arglist, "\@" . $arg->{'location'} . '("' . $arg->{'name'} . '") ' . $arg->{'type'} . ' ' . $arg->{'name'};

  }

  print OUT " // " . $rref->{'description'} . "\n";

  print OUT " \@FormUrlEncoded\n" if ($bodyarg == 1);

  print OUT " \@" . $rref->{'method'} . '("' . $rref->{'path'} . "\")\n";

  $args = join ", ", @arglist;

  print OUT " public Response " . $rref->{'name'} . "($args);\n";

  print OUT "\n";

}

print OUT "}\n";

close OUT;

}

sub PMgr()

{

open OUT, "> $SHR/webservice/PersonalizationManager.java";

print OUT << "EOT";

package eu.alfred.api.personalization.webservice;

import android.os.Bundle;

import android.os.Handler;

import android.os.Message;

import android.os.Messenger;

import android.os.RemoteException;

import com.google.gson.Gson;

import org.json.JSONArray;

import org.json.JSONException;

import org.json.JSONObject;

import eu.alfred.api.personalization.model.*;

import eu.alfred.api.personalization.responses.PersonalizationResponse;

import eu.alfred.api.personalization.client.*;

public class PersonalizationManager {

    private Messenger messenger;

    private class PersonalizationSuccessResponse extends Handler {

        private PersonalizationResponse personalizationSuccessResponse;

        public PersonalizationSuccessResponse(PersonalizationResponse personalizationSuccessResponse) {

            this.personalizationSuccessResponse = personalizationSuccessResponse;

        }

        \@Override

        public void handleMessage(Message msg) {

            int respCode = msg.what;

            switch (respCode) {

                case PersonalizationConstants.CREATE_USER_PROFILE_RESPONSE:

                case PersonalizationConstants.UPDATE_USER_PROFILE_RESPONSE:

                case PersonalizationConstants.DELETE_USER_PROFILE_RESPONSE:

                case PersonalizationConstants.CREATE_USER_CONTACT_RESPONSE:

                case PersonalizationConstants.UPDATE_USER_CONTACT_RESPONSE:

                case PersonalizationConstants.DELETE_USER_CONTACT_RESPONSE:

                case PersonalizationConstants.CREATE_REQUESTER_RESPONSE:

                case PersonalizationConstants.UPDATE_REQUESTER_RESPONSE:

                case PersonalizationConstants.DELETE_REQUESTER_RESPONSE:

                case PersonalizationConstants.ADD_MEMBER_TO_GROUP_RESPONSE:

                case PersonalizationConstants.CREATE_GROUP_RESPONSE:

                case PersonalizationConstants.DELETE_GROUP_RESPONSE:

                case PersonalizationConstants.DELETE_USER_HEALTH_PROFILE_RESPONSE:

                case PersonalizationConstants.UPDATE_GROUP_RESPONSE:

                case PersonalizationConstants.UPDATE_USER_HEALTH_PROFILE_RESPONSE:

                case PersonalizationConstants.CREATE_USER_HEALTH_PROFILE_RESPONSE:

                case PersonalizationConstants.REMOVE_MEMBER_FROM_GROUP_RESPONSE:

                    JSONObject jsonResponse = null;

                    try {

                        jsonResponse = new JSONObject(msg.getData().getString("JsonData", "{}"));

                        personalizationSuccessResponse.OnSuccess(jsonResponse);

                    } catch (JSONException e) {

                        e.printStackTrace();

                        personalizationSuccessResponse.OnError(e);

                    }

                    break;

            }

        }

    }

    private class PersonalizationDataResponse extends Handler {

        private PersonalizationResponse personalizationDataResponse;

        public PersonalizationDataResponse(PersonalizationResponse personalizationDataResponse) {

            this.personalizationDataResponse = personalizationDataResponse;

        }

        \@Override

        public void handleMessage(Message msg) {

            int respCode = msg.what;

            switch (respCode) {

                case PersonalizationConstants.CREATE_USER_PROFILE_FILTER_RESPONSE:

                case PersonalizationConstants.CREATE_USER_PROFILE_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_CONTACTS_BY_CRITERIA_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_PROFILES_LAST_SYNC_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_PROFILE_RESPONSE:

                case PersonalizationConstants.UPDATE_REQUESTER_RESPONSE:

                case PersonalizationConstants.UPDATE_USER_CONTACT_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_PROFILES_BY_CRITERIA_RESPONSE:

                case PersonalizationConstants.RETRIEVE_REQUESTER_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_REQUESTER_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_CONTACTS_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_ID_RESPONSE:

                case PersonalizationConstants.GET_UNSYNCHRONIZED_USER_PROFILES_RESPONSE:

                case PersonalizationConstants.RETRIEVE_ALL_USER_CONTACTS_RESPONSE:

                case PersonalizationConstants.RETRIEVE_GROUP_RESPONSE:

                case PersonalizationConstants.RETRIEVE_GROUPS_WITH_MEMBER_RESPONSE:

                case PersonalizationConstants.RETRIEVE_FILTERED_GROUPS_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_CONTACT_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_HEALTH_PROFILE_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_PROFILE_SENSORED_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USER_PROFILES_RESPONSE:

                case PersonalizationConstants.RETRIEVE_USERS_GROUPS_RESPONSE:

                case PersonalizationConstants.UPDATE_GROUP_RESPONSE:

                    JSONArray jsonResponse = null;

                    try {

                        jsonResponse = new JSONArray(msg.getData().getString("response"));

                        personalizationDataResponse.OnSuccess(jsonResponse);

                    } catch (JSONException e) {

                        e.printStackTrace();

                        personalizationDataResponse.OnError(e);

                    }

                    break;

            }

        }

    }

    public PersonalizationManager(Messenger messenger) {

        this.messenger = messenger;

    }

EOT

for my $rref (@calls)

{

  my $bodyarg = 0;

  my @arglist;

  for my $arg (@{$rref->{'args'}})

  {

    $bodyarg = 1 if ($arg->{'location'} eq 'Field');

    push @arglist, $arg->{'type'} . ' ' . $arg->{'name'};

  }

  print OUT "\n\t// " . $rref->{'description'} . "\n";

  $args = join ", ", @arglist;

  my $name = $rref->{'name'};

  my $nameUC = &camelCaseToCapitals($name);

  my $restype = ($name =~ /^(get|retrieve)/) ? "Data" : "Success";

  print OUT << "EOT";

    public void ${name}(${args}, PersonalizationResponse response) {

        if (messenger != null) {

            Message msg = Message.obtain(null, PersonalizationConstants.${nameUC});

            if (response != null)

                msg.replyTo = new Messenger(new Personalization${restype}Response(response));

            Bundle data = new Bundle();

EOT

  my $useGson = 0;

  for my $arg (@{$rref->{'args'}})

  {

    my $at = $arg->{'type'};

    $useGson = 1 unless ($at eq 'String');

  }

  print OUT "\t\t\tGson gson = new Gson();\n" if $useGson == 1;

  for my $arg (@{$rref->{'args'}})

  {

    my $an = $arg->{'name'};

    my $at = $arg->{'type'};

    if ($at eq 'String')

    {

      print OUT "\t\t\tdata.putString(\"$an\", ${an});\n";

    }

    else

    {

      print OUT "\t\t\t${at}Dto ${an}Dto = ${at}Mapper.toDto($an);\n";

      print OUT "\t\t\tString ${an}Json = gson.toJson(${an}Dto);\n";

      print OUT "\t\t\tdata.putString(\"$an\", ${an}Json);\n";

    }

  }

  print OUT << "EOT";

            msg.setData(data);

            try {

                messenger.send(msg);

            } catch (RemoteException e) {

                e.printStackTrace();

            }

        }

    }

EOT

}

print OUT "}\n";

close OUT;

}

sub tfac()

{

open OUT, "> $PAS/PersonalizationCRUDTaskFactory.java";

print OUT << "EOT";

package eu.alfred.personalassistant.service.personalization;

import android.content.Context;

import android.os.AsyncTask;

import eu.alfred.api.personalization.webservice.PersonalizationConstants;

import eu.alfred.personalassistant.service.personalization.tasks.CreateUserProfileTask;

import eu.alfred.personalassistant.service.personalization.tasks.RetrieveUserProfileTask;

public class PersonalizationCRUDTaskFactory {

    public static AsyncTask<PersonalizationMessageClass, Void, String> GetInstance(Context context, int msgType){

        switch(msgType){

EOT

for my $rref (@calls)

{

  my $name = $rref->{'name'};

  my $nameuc = ucfirst($name);

  my $nameUC = &camelCaseToCapitals($name);

  print OUT "\t\t\t// " . $rref->{'description'} . "\n";

  print OUT "\t\t\tcase PersonalizationConstants.${nameUC}:\n";

  print OUT "\t\t\t\treturn new ${nameuc}Task(context);\n";

}

print OUT << "EOT";

            default:

                throw new IllegalArgumentException("The parameter value is invalid. Value: " + String.valueOf(msgType));

        }

    }

}

EOT

close OUT;

}

sub client()

{

for my $rref (@calls)

{

  my $name = $rref->{'name'};

  my $nameuc = ucfirst($name);

  my $response = $rref->{'response'};

#  next if $name ne 'createUserProfile';

# -------------------- Client -----------------------------

  my $requestparams = '';

  my @arglist;

  for my $par (@{$rref->{'args'}})

  {

    my $pn = $par->{'name'};

    my $pt = $par->{'type'};

    if ($pt eq 'String' && $pn =~ /id$/i)

    {

      $requestparams .= "\t\t$pt $pn = request.$pn;\n";

    }

    elsif ($pt eq 'String' && $par->{'location'} eq 'Field' && $pn eq 'valuesToUpdate')

    {

      $requestparams .= "\t\t$pt $pn = request.valuesToUpdate;\n";

    }

    else

    {

      $requestparams .= "\t\t$pt $pn = new ${pt}Mapper().toModel(request.${pn});\n";

    }

    push @arglist, $pn;

  }

  my $requestarglist = join ', ', @arglist;

  my $responsetype = "${nameuc}Response";

  if ($response eq 'String')

  {

    $responsetype = "StringResponse";

  }

  elsif ($response eq 'List<UserProfile>')

  {

    $responsetype = "UserProfileResponse";

  }

  elsif ($response eq 'List<HealthProfile>')

  {

    $responsetype = "HealthProfileResponse";

  }

  elsif ($response eq 'List<Group>')

  {

    $responsetype = "GroupResponse";

  }

  elsif ($response eq 'List<Contact>')

  {

    $responsetype = "ContactResponse";

  }

  elsif ($response eq 'List<Requester>')

  {

    $responsetype = "RequesterResponse";

  }

  open OUT, "> $TRG/client/client/${nameuc}Client.java";

  print OUT << "EOT";

package alfred.eu.personalizationmanagerapi.client.client;

import android.content.Context;

import alfred.eu.personalizationmanagerapi.PersonalizationManagerAdapter;

import alfred.eu.personalizationmanagerapi.PersonalizationManagerService;

import alfred.eu.personalizationmanagerapi.client.ClientResponse;

import alfred.eu.personalizationmanagerapi.client.dto.*;

import alfred.eu.personalizationmanagerapi.client.mapper.StringResponseMapper;

import alfred.eu.personalizationmanagerapi.client.mapper.UserProfileMapper;

import alfred.eu.personalizationmanagerapi.client.request.${nameuc}Request;

import alfred.eu.personalizationmanagerapi.client.response.${responsetype};

import alfred.eu.personalizationmanagerapi.util.Strings;

import retrofit.client.Response;

public class ${nameuc}Client extends Client<${nameuc}Request, ClientResponse<${responsetype}>> {

  public ${nameuc}Client(Context context) {

      super(context);

  }

  \@Override

  protected ClientResponse<${responsetype}> request(${nameuc}Request request) throws Exception {

      PersonalizationManagerService service = PersonalizationManagerAdapter.getInstance(getContext()).getService();

${requestparams}

      Response serviceResponse = service.${name}(${requestarglist});

      printResponse(serviceResponse);

EOT

  if ($response eq 'String')

  {

    print OUT << "EOT";

      ClientResponse<StringResponse> response = new StringResponseMapper().mapResponse(

              Strings.convertStreamToString(serviceResponse.getBody().in(), "UTF-8"));

EOT

  }

  else

  {

    print OUT << "EOT";

      ClientResponse<${response}> response = new ${responsetype}Mapper().mapResponse(

              Strings.convertStreamToString(serviceResponse.getBody().in(), "UTF-8"));

EOT

  }

    print OUT << "EOT";

      if ("OK".equals(response.status)) {

          return response;

      } else {

          throw new Exception("${nameuc} failed");

      }

  }

}

EOT

  close OUT;

 }

}

sub task()

{

for my $rref (@calls)

{

  my $name = $rref->{'name'};

  my $nameuc = ucfirst($name);

  my $response = $rref->{'response'};

  my $nameUC = &camelCaseToCapitals($name);

#  next if $name ne 'createUserProfile';

#  next if $name ne 'createUserContact';

# -------------------- Task -----------------------------

  my $requestparams = '';

  my @arglist;

  for my $par (@{$rref->{'args'}})

  {

    if ($par->{'type'} eq 'String' && $par->{'name'} =~ /id$/i)

    {

      $requestparams .= "\t\t" . $par->{'type'} . " " . $par->{'name'} . " = request." . $par->{'name'} . ";\n";

    }

    elsif ($par->{'type'} eq 'String' && $par->{'location'} eq 'Field' && $par->{'name'} eq 'valuesToUpdate')

    {

      $requestparams .= "\t\t" . $par->{'type'} . " " . $par->{'name'} . " = request.valuesToUpdate;\n";

    }

    else

    {

      $requestparams .= "\t\t" . $par->{'type'} . " " . $par->{'name'} . " = new " . $par->{'type'} . "RequestMapper().toModel(request);\n";

    }

    push @arglist, $par->{'name'};

  }

  my $requestarglist = join ', ', @arglist;

  my $responsetype = "${nameuc}Response";

  if ($response eq 'String')

  {

    $responsetype = "StringResponse";

  }

  elsif ($response eq 'List<UserProfile>')

  {

    $responsetype = "UserProfilesResponse";

  }

  elsif ($response eq 'List<HealthProfile>')

  {

    $responsetype = "HealthProfilesResponse";

  }

  elsif ($response eq 'List<Group>')

  {

    $responsetype = "GroupsResponse";

  }

  elsif ($response eq 'List<Contact>')

  {

    $responsetype = "ContactsResponse";

  }

  elsif ($response eq 'List<Requester>')

  {

    $responsetype = "RequestersResponse";

  }

  open OUT, "> $PAS/tasks/${nameuc}Task.java";

  print OUT << "EOT";

package eu.alfred.personalassistant.service.personalization.tasks;

import android.content.Context;

import android.os.AsyncTask;

import android.os.Bundle;

import android.os.Message;

import android.os.RemoteException;

import android.util.Log;

import com.google.gson.Gson;

import alfred.eu.personalizationmanagerapi.client.ClientResponse;

import alfred.eu.personalizationmanagerapi.client.client.${nameuc}Client;

import alfred.eu.personalizationmanagerapi.client.request.${nameuc}Request;

import alfred.eu.personalizationmanagerapi.client.response.${responsetype};

EOT

  for my $par (@{$rref->{'args'}})

  {

    my $pt = $par->{'type'};

    if ($pt ne 'String')

    {

      print OUT "import eu.alfred.api.personalization.client.${pt}Dto;\n";

      print OUT "import alfred.eu.personalizationmanagerapi.client.mapper.${pt}ResponseMapper;\n";

    }

  }

print OUT << "EOT";

import eu.alfred.api.personalization.webservice.PersonalizationConstants;

import eu.alfred.personalassistant.service.personalization.PersonalizationMessageClass;

public class ${nameuc}Task extends AsyncTask<PersonalizationMessageClass, Void, String> {

    private final static String TAG = "${nameuc}Task";

    private Context context;

    private PersonalizationMessageClass msg;

    private Exception exception;

    public ${nameuc}Task(Context context) {

        this.context = context;

    }

    \@Override

    protected String doInBackground(PersonalizationMessageClass... params) {

        try {

            msg = params[0];

            ${nameuc}Request request = new ${nameuc}Request();

EOT

  for my $par (@{$rref->{'args'}})

  {

    my $pn = $par->{'name'};

    my $pt = $par->{'type'};

    if ($pt eq 'String')

    {

      print OUT "\t\t\trequest.$pn = msg.data.getString(\"$pn\");\n";

    }

    else

    {

      print OUT "\t\t\trequest.$pn = new Gson().fromJson(msg.data.getString(\"$pn\"), ${pt}Dto.class);\n";

    }

  }

  print OUT << "EOT";

            ${nameuc}Client client = new ${nameuc}Client(context);

            ClientResponse<${responsetype}> response = client.execute(request);

            if (response.errorCode != 0)

                exception = new Exception("(" + response.errorCode + ") " + response.status);

EOT

  if ($response eq 'String')

  {

    print OUT "\t\t\tString result = response.data.string;\n";

  }

  else

  {

    print OUT "\t\t\tString result = new ${responsetype}Mapper().toModel(response.data);\n";

  }

  print OUT << "EOT";

            return new Gson().toJson(result);

        } catch (Exception e) {

            exception = e;

            Log.e(TAG, e.getClass().getSimpleName(), e);

        }

        return null;

    }

    \@Override

    protected void onPostExecute(String result) {

        super.onPostExecute(result);

        Message resp = Message.obtain(null, PersonalizationConstants.${nameUC}_RESPONSE);

        Bundle bundle = new Bundle();

        bundle.putString(PersonalizationConstants.EXTRAS_JSON, result);

        if (exception != null)

            bundle.putString(PersonalizationConstants.EXTRAS_EXCEPTION, exception.getClass().getSimpleName() + ": " + exception.getMessage());

        resp.setData(bundle);

        try {

            msg.replyTo.send(resp);

        } catch (RemoteException e) {

            Log.e(TAG, e.getClass().getSimpleName(), e);

        }

    }

}

EOT

  close OUT;

 }

}

sub request()

{

for my $rref (@calls)

{

  my $name = $rref->{'name'};

  my $nameuc = ucfirst($name);

  my $response = $rref->{'response'};

  my $nameUC = &camelCaseToCapitals($name);

# -------------------- Request -----------------------------

  open OUT, "> $TRG/client/request/${nameuc}Request.java";

  print OUT << "EOT";

package alfred.eu.personalizationmanagerapi.client.request;

import com.google.gson.annotations.Expose;

public class ${nameuc}Request {

EOT

  for my $par (@{$rref->{'args'}})

  {

    print OUT "\t\@Expose\n";

    print OUT "\tpublic " . $par->{'type'} . " " . $par->{'name'} . ";\n";

  }

  print OUT "}\n";

  close OUT;

 }

}

sub response()

{

for my $rref (@calls)

{

  my $name = $rref->{'name'};

  my $nameuc = ucfirst($name);

  my $response = $rref->{'response'};

  my $nameUC = &camelCaseToCapitals($name);

# -------------------- Response -----------------------------

  my $resobj = $name;

  $resobj =~ s/^[a-z]*([A-Z])//;

  $resobj = lc($1) . $resobj;

  open OUT, "> $TRG/client/response/${nameuc}Response.java";

  print OUT << "EOT";

package alfred.eu.personalizationmanagerapi.client.response;

import com.google.gson.annotations.Expose;

public class ${nameuc}Response {

  \@Expose

  public ${response} ${resobj};

}

EOT

  close OUT;

}

}

print "apigenerator [PMservice/PMgr/client/task/request/response]\n";

for my $t (@ARGV)

{

  &PMservice() if $t eq 'PMservice';

  &PMgr() if $t eq 'PMgr';

  &tfac() if $t eq 'tfac';

  &client() if $t eq 'client';

  &task() if $t eq 'task';

  &request() if $t eq 'request';

  &response() if $t eq 'response';

}