eagle-security/eagle-security-common/src/test/java/org/apache/eagle/security/crawler/audit/TestHDFSAuditLogParser.java

/*
 *
 *  * Licensed to the Apache Software Foundation (ASF) under one or more
 *  * contributor license agreements.  See the NOTICE file distributed with
 *  * this work for additional information regarding copyright ownership.
 *  * The ASF licenses this file to You under the Apache License, Version 2.0
 *  * (the "License"); you may not use this file except in compliance with
 *  * the License.  You may obtain a copy of the License at
 *  *
 *  *    http://www.apache.org/licenses/LICENSE-2.0
 *  *
 *  * Unless required by applicable law or agreed to in writing, software
 *  * distributed under the License is distributed on an "AS IS" BASIS,
 *  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  * See the License for the specific language governing permissions and
 *  * limitations under the License.
 *
 */

package org.apache.eagle.security.crawler.audit;

import org.apache.eagle.security.hdfs.HDFSAuditLogParser;
import org.apache.eagle.security.hdfs.HDFSAuditLogObject;
import junit.framework.Assert;
import org.junit.Test;

public class TestHDFSAuditLogParser {
    @Test
    public void testParser() throws Exception{
        HDFSAuditLogParser parser = new HDFSAuditLogParser();
        HDFSAuditLogObject entity =
                parser.parse("2015-09-21 21:36:52,172 INFO FSNamesystem.audit: allowed=true   ugi=user1@APD.xyz.com (auth:SIMPLE)     ip=/10.0.2.15   cmd=getfileinfo src=/tmp/hive   dst=null        perm=null       proto=rpc\n");
        Assert.assertEquals("user1", entity.user);
        Assert.assertEquals(new Boolean(true), entity.allowed);

        entity = parser.parse("2015-09-21 21:36:52,172 INFO FSNamesystem.audit: allowed=true ugi=hadoop/host123.xyz.com@APD.xyz.com (auth:SIMPLE)     ip=/10.0.2.15   cmd=getfileinfo src=/tmp/hive   dst=null        perm=null       proto=rpc\n");
        Assert.assertEquals("hadoop", entity.user);
        Assert.assertEquals(new Boolean(true), entity.allowed);
    }
}