ハグで連絡先交換 「Hug Protocol」の実装

#!/usr/bin/python

# -*- coding: utf8 -*-

#  This is built based on the MFRC522-Python Read.py

import requests

import RPi.GPIO as GPIO

import MFRC522

import signal

continue_reading = True

# 予め自分のユーザIDを設定する

src_uid = 1

#サーバアドレスs

url = "http://satosugar.php.xdomain.jp/db_write_authenticate.php"

#相手のユーザIDリスト

uid_list = []

# 配列を数値に直す

def change_to_num(target):

   target = target[::-1]

   result = 0

   itera = 0

   for i in target:

       result = result + i * pow(10, itera)

       itera = itera + 1

   return int(result)

# データベースに入れる

def insert_data(src_id, des_id):

   print(uid_list)

   if src_id == des_id:

       return

   r = requests.get(url, params= {"src":src_id, "des":des_id})

   print "inserted"

# Capture SIGINT for cleanup when the script is aborted and insert obtained uid to database

def end_read(signal,nframe):

   global continue_reading

   print "Contacts added and end reading."

   continue_reading = False

   GPIO.cleanup()

# Hook the SIGINT

signal.signal(signal.SIGINT, end_read)

# Create an object of the class MFRC522

MIFAREReader = MFRC522.MFRC522()

while continue_reading:

   # Scan for cards

   (status, TagType) = MIFAREReader.MFRC522_Request(MIFAREReader.PICC_REQIDL)

   # If a card is found

   if status == MIFAREReader.MI_OK:

       print "Card detected"

   #カードやタグのID番号の取得d

   (status,uid) = MIFAREReader.MFRC522_Anticoll()

    もし取得できたら、次に進みe

   if status == MIFAREReader.MI_OK:

       # Printカードの UID

       print "Card read UID: %s,%s,%s,%s" % (uid[0], uid[1], uid[2], uid[3])

       # This is the default key for authentication

       key = [0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF]

       # Select the scanned tag

       MIFAREReader.MFRC522_SelectTag(uid)

       # Authenticate

       status = MIFAREReader.MFRC522_Auth(MIFAREReader.PICC_AUTHENT1A,08, key, uid)

       # Check if authenticated

       if status == MIFAREReader.MI_OK:

           MIFAREReader.MFRC522_Read08

           # カードに書き込んだ情報を読み込む)

           des_uid = MIFAREReader.MFRC522_Return_Data08)

           print des_uid

           MIFAREReader.MFRC522_StopCrypto1()

           #読み取ったユーザIDを数値に直し、サーバに入れるd

          # print(uid_list)

           des_uid = change_to_num(des_uid)

           if des_uid in uid_list:

               print "Already in list."

           else:

               uid_list.append(des_uid)

               print "\n inserting data"

               insert_data(src_uid, des_uid)

       else:

           print "Authentication error

static public ArrayList<UserProfile> userProfiles;

static public ListView listView;

listView = findViewById(R.id.listViewContainer);
adapter = new ArrayAdapter<>(this,
android.R.layout.simple_list_item_1, android.R.id.text1, userNames);
listView.setAdapter(adapter);
listView.setTextFilterEnabled(true);

// Set OnClick Listener for ListView item
listView.setOnItemClickListener(new OnItemClickListener() {
   public void onItemClick(AdapterView<?> parent, View view,
   int position, long id) {
　　// When click, show detail of each user
　　Intent intent = new Intent(context, SingleViewActivity.class);
　　intent.putExtra("profile", userProfiles.get(position));
　　context.startActivity(intent);
   }
});

// Set OnClick Listener for SYNC button
Button syncButton = findViewById(R.id.syncButton);
syncButton.setOnClickListener(new View.OnClickListener() {
   @Override
   public void onClick(View v) {
　　　　String uid = MainActivity.myProfile.featureMap.get("uid");
　　　　HttpReadTask task = new HttpReadTask(uid);
　　　　task.execute();
   }
});

protected void onPreExecute() {
       String DEFAULTURL = "http://jachivi.sakura.ne.jp/read.php?";
       Uri.Builder builder = Uri.parse(DEFAULTURL).buildUpon();
       builder.appendQueryParameter("uid", uid);
       uri = builder.toString();
   }

protected String doInBackground(Integer... args) {
       return exec_get();
   }

private String exec_get() {
       HttpURLConnection http = null;
       InputStream in = null;
       StringBuilder src = new StringBuilder();

       try {
           Log.v("PiLed", uri);
           URL url = new URL(uri);
           http = (HttpURLConnection) url.openConnection();
           http.setRequestMethod("GET");
           http.setDoInput(true);
           http.connect();

           int code = http.getResponseCode();
           Log.v("UPDATE", Integer.toString(code));

           in = http.getInputStream();
           byte[] line = new byte[1];
           int size;
           while (true) {
               size = in.read(line);
               if (size <= 0)
                   break;
               src.append(new String(line));
           }
       } catch (Exception e) {
           e.printStackTrace();
       } finally {
           try {
               if (http != null)
                   http.disconnect();
               if (in != null)
                   in.close();
           } catch (Exception ignored) {
           }
       }

       return src.toString();
   }

protected void onPostExecute(String result) {
       if (result.length() > 0) {
           // Split the result in to user's profile strings
           String users[] = result.split(";");
           for (String user : users) {
               userProfiles.add(new UserProfile(user));
           }
           ListViewActivity.setUserProfiles(userProfiles);
       }
   }

カラム名

src

des

型

int

int

カラム名

uid

Name

Email

Phone

Birthday

Facebook

Twitter

Github

型

int

text

text

text

date

text

text

text

$link = mysqli_connect($url,$user,$pass) or die("MySQL接続失敗");

$sdb = mysqli_select_db($link,$db) or die("データベース選択失敗");

$uid = (int)$_GET["uid"];

$name = $_GET["name"];

$mail = $_GET["mail"];

$phone = $_GET["phone"];

$birthday = $_GET["birthday"];

$facebook = $_GET[“facebook”];

$twitter  = $_GET[“twitter”];

$github = $_GET[“github”];

$sql = "INSERT INTO users (uid,name,birthday,phone,mail) VALUES ($uid, $name, $birthday, $phone, $mail, $facebook, $twitter, $github)";

$result_flag = mysqli_query($link, $sql) or die('INSERTクエリーが失敗しました。'.mysqli_error($link));

　　　 $link = mysqli_connect($url,$user,$pass) or die("MySQL接続失敗");

$sdb = mysqli_select_db($link,$db) or die("データベース選択失敗");

$uid = $_GET["uid"];

$sql = "SELECT *  FROM users

　　　　　　　WHERE uid

                        IN (

                              SELECT des FROM relation

                                 WHERE src =$uid

                              )";

$result = mysqli_query($link, $sql);

if(!$result) {

echo "SELECTクエリー失敗\n";

}

$link = mysqli_connect($url,$user,$pass) or die("MySQL接続失敗");

$sdb = mysqli_select_db($link,$db) or die("データベース選択失敗");

$src = (int)$_GET["src"];

$des = (int)$_GET["des"];

$sql = "INSERT INTO relation (src,des) VALUES ($src, $des)";

$result_flag = mysqli_query($link, $sql) or die('INSERTクエリーが失敗しました。'.mysqli_error($link));