mares-mongoose-model

슬로그업에서 사용하는 node.js DDD패턴 구현 시 필요합니다. mongoose 모델 생성시 반드시 해당 모듈을 상속받아야 합니다.

Installation

npm install --save mares-mongoose-model

Examples

const MaresMongooseModel = require('mares-mongoose-model')

// 다음과 같이 몽구스 모델을 상속받아 추가 함수를 구현해서 사용합니다.
class TestModel extends MaresMongooseModel {  
	/**
	 * 문자열로 몽구스 프로젝션에 필요한 필드를 정의합니다.
	 * @override
	 */
	static getAttributes() {  
		return 'id a b' 
	} 
	
	/**
	 * 다음함수는 기본 몽구스의 함수를 오버라이딩 하는 경우입니다.
	 * @override
	 * @static
	 */
	static findById() {
		//todo
	}
	
	static doSomething() {}  
}  

Action

모든 개발 패턴을 통일하기 위하여 에러핸들링, parameter 핸들링, return data의 정규화 등을 내부 지정된 함수를 이용해서 조작해야 합니다.

Mongoose error object handling

몽구스에서 나는 모든 에러는 catch 후 해당 함수를 통해서 전파해야 합니다. 내부적으로 throw를 하기 때문에 명시적으로 throw를 적을 필요가 없습니다.

class TestModel extends MaresMongooseModel {  
    static doSomething() {  
        try { 
            // call mongoose built-in method
        } catch (e) {
            this.throwRefineError(e)  
        }
    }
}  

404 error handling

데이터가 없는 경우 404에러를 throw 해줍니다.

class TestModel extends MaresMongooseModel {  
	static async doSomething() {  
		let data = await get()  
		if (data === null) {
			// 데이터가 없다면 바로 404 error를 throw한다.
			this.throwNotfoundError()
		} 
	}
}  

Parameter normalization

infra / repository 에는 domain layer의 PO가 넘어오는 경우가 많기 때문에 반드시 일반객체로 정규화 한 후 사용해야 합니다.

class TestModel extends MaresMongooseModel {  
	static async doSomething(domainObject) {
	  
		// object 인경우
		let pureObject = this.cleanObject(domainObject)
		
		// array 인경우
		let pureArray = this.cleanArray(domainObject)
	}
}  

Return mongoose object

mongoose object를 pure함수를 통해 po로 변형 후 return 해야 합니다.

class TestModel extends MaresMongooseModel {  
	static async doSomething(domainObject) {  
		let data = await get()  
		return this.toPure(data)
	}
}  

Get projection query

몽고디비의 프로젝션에 필요한 쿼리를 만들어 줍니다. 해당 함수는 내부적으로 getAttributes() 함수를 이용합니다.

class TestModel extends MaresMongooseModel {
	static getAttributes() {
		return 'id test value app.a app.b app.c.a app.c.b'  
	}
	static async doSomething(domainObject) {  
		let data = await get()  
		let projection = this.getProjection('', 'prefix') //빈문자열을 이용하면 getAttributes 함수를 이용합니다.
		/**
		 * prjection 객체는 다음과 같이 변환됩니다. 
		 * {
		 *  	'prefix.id': 1,  
		 *  	'prefix.test': 1,  
		 *  	'prefix.value': 1,  
		 *  	'prefix.app.a': 1,  
		 *  	'prefix.app.b': 1,  
		 *  	'prefix.app.c.a': 1,  
		 *  	'prefix.app.c.b': 1
		 * }
		 */
		// todo
	}
}  

Build group query

조인을 위한 쿼리를 생성하기 위한 함수를 제공합니다. 몽구스에서 조인을 하게 되면, 응답형태를 다시 객체로 만들어야 하는데 이를 자동으로 해주는 함수를 제공합니다. 아래는 order-orderItem-inventory 3개를 조인하는 예제코드 입니다. (왼쪽에서 부터 오른쪽으로 1:N 관계입니다.)

class TestModel extends MaresMongooseModel {
	static async findFullOrder(appKey, order, orderItem = null) {
		// 최초 모든 프로젝션 값을 얻어옵니다.
		const orderItemAttr = mongoose.models.OrderItem.getAttributes()  
		const inventoryAttr = mongoose.models.Inventory.getAttributes()  
		const orderAttr = this.getAttributes()  
		
		// 쿼리작성을 시작합니다.
		let aggregateQuery = []
		
		// 먼저 appKey라는 필드를 검색합니다.
		aggregateQuery.push({  
            $match: {  
                appKey  
            }  
		})
		
		// join을 합니다. $lookup 키워드를 이용합니다.
		// from은 N관계의 join할 컬렉션명입니다.
		// foreignField는 OrderItem에서 들고있는 외래키의 이름입니다.
		// localField는 order의 고유키입니다. (primary Key)
		// as는 해당 N관계의 값들이 포함될 필드명입니다. 아래 배열로 들어갑니다.
		aggregateQuery.push({  
            $lookup: {  
                from: 'OrderItem',  
                foreignField: 'order',  
                localField: '_id',  
                as: 'orderItems'  
            }  
		})
		
		// unwind를 하게 되면 orderItems안의 배열의 값들이 모두 펼쳐지면서 각각의 로우로 변경됩니다. orderItems를 들고 있는 객체의 모든 필드는 중복됩니다.
		aggregateQuery.push({$unwind: '$orderItems'})  
		
		aggregateQuery.push({  
            $match: {  
                'orderItems.canceledAt': {$exists: false},  
            }  
		})  
		
		aggregateQuery.push({  
            $lookup: {  
                from: 'Inventory',  
                foreignField: 'orderItem',  
                localField: 'orderItems._id',  
                as: 'orderItems.inventories'  
            }
		})  
		aggregateQuery.push({$unwind: '$orderItems.inventories'})  
		aggregateQuery.push({  
            $match: {  
                'orderItems.inventories.canceledAt': {$exists: false}  
            }  
		})  
		aggregateQuery.push({$limit: 1})

		// buildGroupQuery를 이용하여 실제로 그룹핑을 위한 쿼리를 만듭니다.
		// 앞에 문자열은 root collection명을 제외한 depth 구조입니다. 닷(점)으로 구분합니다. 또한 최종 lookup 구문의 as와 동일합니다.
		// 두번째 인자는 프로젝션 스트링 값입니다. 만일 위에 depth의 닷이 1개라면 총 3개의 프로젝션 값이 필요합니다.
		aggregateQuery = [...aggregateQuery, ...this.buildGroupQuery('orderItems.inventories', [orderAttr, orderItemAttr, inventoryAttr])]  
		try {  
            let orders = await this.aggregate(aggregateQuery)  
            if (!orders || orders.length === 0) this.throwNotfoundError()  
            return this.toPure(orders[0])  
		} catch (e) {  
            this.throwRefineError(e)  
		}  
	}
}

Remove null fields

클라이언트에서 생성시(POST) 생성할 필드가 없을때 null을 보낼 수 있는데 이때 null 값을 모두 제거하여 생성시 $set의 필드에 null이 들어가는 것을 방지하기 위한 함수 입니다.

class TestModel extends MaresMongooseModel {
	static async doSomething(domainObject) {  
		// obj의 null값을 제거해줍니다.
		// 만일 모든 sub object 혹은 sub array의 값이 모두 null이면 해당 객체나 배열은 단순 null로 바뀝니다.
		// 두번째 인자는 undefined or {}, []값을 없애줄지 여부 입니다.
		this.removeNullFields(obj, true)
	}
}  

Generate unset query

값을 수정할 때 null을 보내면 해당 필드를 unset으로 제거하여 주고 싶을 때 사용합니다.

class TestModel extends MaresMongooseModel {
	static async doSomething(domainObject) {  
		// null 값을 찾아서 unset 쿼리를 만들어 줍니다.
		// 두번째 인자는 unset 쿼리 객체를 만들 때 배열의 원소까지 체크할지 여부입니다. 만일 true 라면 'array.0.a' 와같은 형태로 만들어 주며, false일 경우에는 해당 array 키값을 무시합니다.
		this.toUnsetFromNullFields(obj, true)
	}
}