서버없이 FCM 보내기 - CloudFunction + FireStore + FCM(2)

진행 중인 토이 프로젝트에서 푸시알림을 사용해야됐다. 이전에 Firebase 실시간 DB에 토큰을 저장해서 그걸 읽어들여 푸시알림을 개개인에게 보내는 작업을 진행하려고 했는데 topic을 사용하는 방법을 알게됐다.

https://firebase.google.com/docs/cloud-messaging/android/topic-messaging?hl=ko&authuser=0&_gl=1*1wkaaex*_up*MQ..*_ga*MTU1MjEzMDIyNi4xNzEzNTk0NjM3*_ga_CW55HF8NVT*MTcxNjEwNDkxOS4xNS4xLjE3MTYxMDcwMTguNTUuMC4w

Android에서 주제 메시징  |  Firebase 클라우드 메시징

---

firebase cli 세팅하는 부분은 공식문서에 잘 나와있으니 넘어가겠다.

topic을 기준으로 메시징하기로 결정한 이유는 효율성 때문이다. 모임관리 앱을 만들고 있는 중이고, 어떤 사용자가 모임에 참여하게 되면 이미 모임에 참여중이던 사람들에게 새로운 참여자가 생겼다고 푸시알림으로 보내도록 하려했다. 그래서 처음에는 모임에 있는 사람들의 토큰을 관리하는 collection을 하나 만들어서 그걸로 순회하면서 각 토큰에 fcm을 보내려고 하다가 topic을 사용하면 더 효율적인 메시징이 가능한 것을 알게 됐다. 공식문서에 보면 아래와 같이 나와있는데,

피드백이 빨라야하는 푸시알림이 아니기 때문에 이걸 사용해도 된다고 판단했다.

function은 v2가 아니라 v1을 사용했다.(마이그레이션 경험도 해보기 위해서)

const functions = require('firebase-functions/v1');
const admin = require("firebase-admin");

admin.initializeApp();

exports.detectMeetingJoinWithFCM = functions.firestore
  .document("/DETAILMEETING/{documentId}")
  .onUpdate((change, context) => {
    const documentId = context.params.documentId;

    // 문서가 삭제된 경우는 처리하지 않음
    if (!change.after.exists) {
      functions.logger.log("Document deleted", documentId);
      return null;
    }

    const newValue = change.after.data();
    const previousValue = change.before.data();

    // 문서가 업데이트된 경우
    if (newValue.participants !== previousValue?.participants) {
      const participants = newValue.participants;
      const meetingContent = newValue.meeting;
      functions.logger.log("Detected write", documentId, participants);
      
      const topic = documentId;
      const message = {
        notification: {
          title: `${meetingContent}`,
          body: `이제 모임에 참가자가 ${participants.length}명이 되었습니다`
        },
        topic: topic
      };
      
      return admin.messaging().send(message)
      .then(response => {
        console.log('Successfully sent message:', response);
        return null;
      })
      .catch(error => {
        console.error('Error sending message:', error);
        return null;
      });
    }

	return null;
  });

 

전체 코드다. trigger 부분과 fcm 부분 이렇게 두 개로 나눠서 살펴보자.

# Trigger

exports.detectMeetingJoinWithFCM = functions.firestore
  .document("/DETAILMEETING/{documentId}")
  .onUpdate((change, context) => {
    const documentId = context.params.documentId;

    // 문서가 삭제된 경우는 처리하지 않음
    if (!change.after.exists) {
      functions.logger.log("Document deleted", documentId);
      return null;
    }

    const newValue = change.after.data();
    const previousValue = change.before.data();

    // 문서가 업데이트된 경우
    if (newValue.participants !== previousValue?.participants) {
      const participants = newValue.participants;
      functions.logger.log("Detected write", documentId, participants);
    }

	return null;
  });

cloudfunction은 내장함수에서 firestore를 모니터링할 수 있는 함수를 갖고 있다. 변화가 생길 때 http로 만들어진 함수를 호출하는 게 아니라, 직접 firestore를 바라보게 해서 클라이언트 쪽에서 호출하지 않아도 클라우드 환경에서 변화를 감지한다. 이때 가장 중요한게 collection 이름에 오타를 내지 않는 것이다... 내 경우에는 _ 하나를 잘못 넣어서 30분 동안 에러 원인을 찾고 있었다.

firestore안에 변화가 생긴 document를 알아서 탐지한다. 그 documentId를 토픽으로 사용할 것이기 때문에 변수에 저장해주고, 변화가 생긴 부분은 change를 통해 접근할 수 있다.

생성할 때는 푸시알림을 보낼 필요가 없어서 onUpdate를 사용했다. onDelete는 현재 상황에서 사용하지는 않는데, 나중에 사용할 수도 있을 것 같다.

# FCM

const participants = newValue.participants;
const meetingContent = newValue.meeting;
const topic = documentId;
const message = {
notification: {
      title: `${meetingContent}`,
      body: `이제 모임에 참가자가 ${participants.length}명이 되었습니다`
    },
    topic: topic
};

return admin.messaging().send(message)
    .then(response => {
    	console.log('Successfully sent message:', response);
    	return null;
	})
	.catch(error => {
		console.error('Error sending message:', error);
		return null;
	});

fcm을 구성해서 전송하는 코드다. topic으로 사용하는 건 trigger에서 받아온 document의 id이고, notification으로 JSON 형식으로 데이터를 만들야한다.

 

이제 만들어진 함수를 갖고 emulators:start로 테스트한다음 deploy해주면 끝난다...

 

난 처음에 cloudfunction으로 날린 fcm은 data 메시지가 아니라 notification 일줄 알았다. 그런데 받아보니 data 메시지로 들어오고 있어서 pending intent를 사용한 제어도 가능했다.

도움이 됐다면 댓글이나 공감 버튼 한 번씩 누르고 가주세요!