![](https://cdn.steemitimages.com/DQmW4SKLyMPpeyedbY1hjyhr2cpEkXomECcVTnqFx2VJ7XS/image.png)

안녕하세요. 오늘은 블록체인 기반 Dapp에서 친구 추가 기능에 대해서 이야기 해보려고 합니다.

<H4>편의상 문체가 제 자신에게 편하게 하는 것이라, 경어가 없는 부분은 이해 부탁 드립니다. </H4>

사실 친구 추가는 굉장히 쉬운 기능이라고 생각이 되지만, 문제는 그 뒤에 딸린 것이다. 친구의 글을 어떻게 화면에 보여줄지, 그리고 어떤 순서로 보여줄지 등등..이 어려운 부분은 UX engineer에게 맡기기로 하고..

우선 오늘은 친구 추가에 대해서 구현을 해보려고 한다.

<H4>Interface</H4>

Web쪽에 계신 분들이 CRUD이야기를 많이 하셔서 오늘의 명칭은 이것에 따라 보려고 한다.

createfriend
readfriends  이것만 복수임의 유의!
update는..없으니 생략
deletefriend

각각의 parameter는..

createfriend
input : account (친구의 account정보)
return : success or fail

readfriends
input : N/A (session정보를 기반으로 자동으로 account를 추출)
return : 
result : data : friend account array

deletefriend : create friend와 동일.

<H4>DB구조</H4>

account를 key로 하고, 여기에 friend를 pair로 묶는 구조로, 친구가 3명이면...
account friend pair가 3개가 되는 단순한 형태이다.

DB 이름 : follower

<H4>Operation</H4>

createfriend

follower DB에 account, friend pair를 기록. 만약 기존에 같은 값이 있으면 fail을 return

readfriends

account를 key로 하여 읽은 값을 그대로 return, data라는 이름의 array + result

delete friend

account, friend pair로 찾은 값을 삭제하고 결과를 return

<h4>coding</h4>
아래는 실제 code입니다.

CRUD method들...DB읽기 실패 처리는 있으나..fail return은 없음..!
~~~
const mongo = require('mongodb');
const ObjectId = require('mongodb').ObjectId;
const MongoClient = require('mongodb').MongoClient;
const url = process.env.MONGODB_URI;


exports.createFriend = function(account, friend, callback){
  MongoClient.connect(url, function(err, db) {
	  const dbo = db.db("heroku_dg3d93pq");
	  const myObj = {account : account, follower : friend};
	  dbo.collection("board").insertOne(myobj, function(err, res){
		  if (err) throw err;
		  console.log("1 follower inserted", account, friend);
		  callback("OK");
		  db.close();
	  });
  });  
}

exports.readFriends = function(account, friend, callback){
	MongoClient.connect(url, function(err, db) {
	  const dbo = db.db("heroku_dg3d93pq");
	  const findQuery = {account : account};
	  dbo.collection("board").find(findQuery).toArray(function(err, res){
		  if (err) throw err;
		  console.log("reading follower", res.length);
		  //make body
		  var body = [];
		  for(i = 0;i < res.length; i++){
			  body.push({ data : res[i].friend });
		  }		  
		  callback(body);
		  db.close();
	  });
  });  
}

exports.deleteFriend = function(account, callback){
	MongoClient.connect(url, function(err, db) {
		const dbo = db.db("heroku_dg3d93pq");
		const deleteQuery = {account : account, follower : friend};
		dbo.collection("board").deleteOne(deleteQuery, function(err, res){
			if (err) throw err;
			console.log("1 follower deleted", account, friend);
			callback("OK");
			db.close();
		});
	});
}
~~~

이건 Post method의 routing처리..
모두 callback type으로 맞추니 copy & paste수준으로 처리 가능함.

~~~
  app.post("/createfriend", function(req, res) { 
	  const friend = req.body.account;
	  console.log("createfriend event", friend);
	  follower.createFriend(req.session.account, friend, (result)=>{
		  res.send(result);
	  });
  });

  app.post("/deletefriend", function(req, res) { 
	  const friend = req.body.account;
	  console.log("deletefriend event", friend);
	  follower.deleteFriend(req.session.account, friend, (result)=>{
		  res.send(result);
	  });
  });

  app.post("/readfriends", function(req, res) { 
	  console.log("readfriends event");
	  follower.readFriends(req.session.account,(result)=>{
		  res.send(result);
	  });
  });
~~~

보시기에 어려운 부분은 없을것으로 생각되지만..혹시나 궁금하신 것이 있으시면 댓글을 달아주세요.